mqtt

Oct 28, 2023

Changes in this version

+ func StartBroker(port, WsPort string) error

+ type Client struct

+ func NewClient(host, clientId string) *Client

+ func (p *Client) Close()

+ func (p *Client) Publish(topic string, qos byte, payload interface{}, retain bool)

+ func (p *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler)

+ func (p *Client) Unsubscribe(topic string)