mqtt

Documentation

Index

• func NewPublisher(address string, timeout time.Duration) (messaging.Publisher, error)
• func NewSubscriber(address string, timeout time.Duration, logger log.Logger) (messaging.Subscriber, error)

Functions

func NewPublisher

func NewPublisher(address string, timeout time.Duration) (messaging.Publisher, error)

NewPublisher returns a new MQTT message publisher.

func NewSubscriber

func NewSubscriber(address string, timeout time.Duration, logger log.Logger) (messaging.Subscriber, error)

NewSubscriber returns a new MQTT message subscriber.