MqttPool

Documentation

Index

• func MqttPublishMsg(mqttContext *MqttContext, nRetryInterval time.Duration) bool
• func MqttSubscribeTopic(nRetryInterval time.Duration, topic string, callback mqtt.MessageHandler) bool
• type MqttClient
  • func InitMqttClient(clientIds ...string) *MqttClient
  • func (mqttClient MqttClient) Connect(nInterval time.Duration) bool
  • func (mqttClient MqttClient) Disconnect()
  • func (mqttClient MqttClient) Publish(topic string, msg *string) bool
  • func (mqttClient MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) bool
• type MqttContext

Functions

func MqttPublishMsg

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

func MqttSubscribeTopic

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

Types

type MqttClient

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

func InitMqttClient

func InitMqttClient(clientIds ...string) *MqttClient

Init once.

func (MqttClient) Connect

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

try connect with failed retry interval.

func (MqttClient) Disconnect

func (mqttClient MqttClient) Disconnect()

func (MqttClient) Publish

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

publish message

func (MqttClient) Subscribe

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

subscribe topic

type MqttContext

type MqttContext struct {
	Topic   string
	Message string
}