Documentation ¶
Index ¶
- Variables
- func InitMQTT()
- func StartReceive()
- type MLogger
- type MQTT
- func (m *MQTT) Connect(clientId string, username string, password string, address string, ...)
- func (m *MQTT) Disconnect()
- func (m *MQTT) IsConnect() bool
- func (m *MQTT) Publish(topic string, qos byte, payload string)
- func (m *MQTT) Subscribe(topic string, qos byte, callback paho.MessageHandler) (err error)
- func (m *MQTT) Unsubscribe(topic string) (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var WaterHeaterStatusHandler paho.MessageHandler = func(client paho.Client, msg paho.Message) { glog.WriteVerbose(packageName, "getWHStatus", fmt.Sprintf("TOPIC: %s, Id: %d, QoS: %d\tMSG: %s.\t MQTT status producer", msg.Topic(), msg.MessageID(), msg.Qos(), msg.Payload())) pak := new(base.ReceivePacket) pak.ProductType = 1 pak.Topic = msg.Topic() pak.Payload = string(msg.Payload()[:]) base.MqttStatusCh <- pak }
热水器状态消息订阅处理方法
Functions ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.