mqttclient

Documentation

Index

• Constants
• type MqttClient
  • func NewMqttClient(appID string, caCert *x509.Certificate, timeoutSec int) *MqttClient
  • func (mqttClient *MqttClient) ConnectWithAccessToken(hostPort string, userName string, accessToken string) error
  • func (mqttClient *MqttClient) ConnectWithClientCert(hostPort string, clientCert *tls.Certificate) error
  • func (mqttClient *MqttClient) Disconnect()
  • func (mqttClient *MqttClient) Publish(topic string, message []byte) error
  • func (mqttClient *MqttClient) PublishObject(topic string, object interface{}) error
  • func (mqttClient *MqttClient) SetPrettyPrint(enable bool)
  • func (mqttClient *MqttClient) Subscribe(topic string, handler func(address string, message []byte))
  • func (mqttClient *MqttClient) Unsubscribe(topic string)
• type TopicSubscription

Constants

const DefaultKeepAliveSec = 10

DefaultKeepAliveSec time a keep alive ping is sent. This is the max wait time to discover a broken connection

const DefaultTimeoutSec = 3

DefaultTimeoutSec constant with connection, reconnection and disconnection timeouts

Types

type MqttClient

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

MqttClient client wrapper around pahoClient This addresses problems with reconnect and auto resubscribe while using clean session

func NewMqttClient

func NewMqttClient(appID string, caCert *x509.Certificate, timeoutSec int) *MqttClient

NewMqttClient creates a new MQTT messenger instance.

See ConnectWithAccessToken or ConnectWithClientCert for the two methods of authentication. To avoid hanging, keep the timeout low, if 0 is provided the default of 3 seconds is used

appID application ID to include in the MQTT client ID
caCert with the x509 CA certificate for validating the server connection
timeoutSec to attempt connecting before it is considered failed. Use 0 for default (3)

func (*MqttClient) ConnectWithAccessToken

func (mqttClient *MqttClient) ConnectWithAccessToken(hostPort string, userName string, accessToken string) error

ConnectWithAccessToken connects to the MQTT broker using an access token for authentication If a previous connection exists then it is disconnected first. If no connection is possible this keeps retrying until the timeout is expired. With each retry a backoff period is increased until 120 seconds.

hostPort with address and port for MQTT password authentication
userName to identify as. Must match access token.
password access token to identify with

func (*MqttClient) ConnectWithClientCert

func (mqttClient *MqttClient) ConnectWithClientCert(hostPort string, clientCert *tls.Certificate) error

ConnectWithClientCert connects to the MQTT broker using client certificate authentication

hostPort with address and port for certificate authentication
clientCert client TLS certificate to authenticate the client with the broker. This certificate
 must be signed by the CA of the broker, so that the broker can authenticate the client.

func (*MqttClient) Disconnect

func (mqttClient *MqttClient) Disconnect()

Disconnect the connection to the MQTT broker and unsubscribe from all addresss and set device state to disconnected

func (*MqttClient) Publish

func (mqttClient *MqttClient) Publish(topic string, message []byte) error

Publish a message to a topic address

func (*MqttClient) PublishObject

func (mqttClient *MqttClient) PublishObject(topic string, object interface{}) error

PublishObject marshals an object into json and publishes it to the given topic If jsonIndent is provided then the message is formatted nicely for humans

func (*MqttClient) SetPrettyPrint

func (mqttClient *MqttClient) SetPrettyPrint(enable bool)

SetPrettyPrint enables/disables pretty-print in marshalling json

func (*MqttClient) Subscribe

func (mqttClient *MqttClient) Subscribe(
	topic string, handler func(address string, message []byte))

Subscribe to a address If a subscription already exists, it is replaced. topic: address to subscribe to. This supports mqtt wildcards such as + and # handler: callback handler.

func (*MqttClient) Unsubscribe

func (mqttClient *MqttClient) Unsubscribe(topic string)

Unsubscribe a topic

type TopicSubscription

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

TopicSubscription holds subscriptions to restore after disconnect