mqtt

Documentation

Overview

Package mqtt hold the implementation of the Publisher and PubSub interfaces for the MQTT messaging system, the internal messaging broker of the Mainflux IoT platform. Due to the practical requirements implementation Publisher is created alongside PubSub. The reason for this is that Subscriber implementation of MQTT brings the burden of additional struct fields which are not used by Publisher. Subscriber is not implemented separately because PubSub can be used where Subscriber is needed.

Index

• func NewPubSub(url, queue string, timeout time.Duration, logger log.Logger) (messaging.PubSub, error)
• func NewPublisher(address string, timeout time.Duration) (messaging.Publisher, error)

Functions

func NewPubSub

func NewPubSub(url, queue string, timeout time.Duration, logger log.Logger) (messaging.PubSub, error)

NewPubSub returns MQTT message publisher/subscriber.

func NewPublisher

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

NewPublisher returns a new MQTT message publisher.