MqttPool

package module

v0.0.0-...-30a3e06 Latest Latest Go to latest Published: Jan 13, 2020 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func MqttPublishMsg(mqttContext *MqttContext, nRetryInterval time.Duration) bool

func MqttSubscribeTopic(nRetryInterval time.Duration,
	topic string, callback mqtt.MessageHandler) bool

type MqttClient struct {
	// contains filtered or unexported fields
}

func InitMqttClient(clientIds ...string) *MqttClient

Init once.

func (mqttClient MqttClient) Connect(nInterval time.Duration) bool

try connect with failed retry interval.

func (mqttClient MqttClient) Disconnect()

func (mqttClient MqttClient) Publish(topic string, msg *string) bool

publish message

func (mqttClient MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) bool

subscribe topic

type MqttContext struct {
	Topic   string
	Message string
}