client

Overview ¶

Package client implements a MQTT-SN version 1.2 client with optional DTLS encryption.

Use ClientConfig struct to set various client's options and features.

Example:

import (
	"fmt"
	"time"

	"github.com/energomonitor/bisquitt/client"
	"github.com/energomonitor/bisquitt/util"
)

func main() {
	brokerAddress := "localhost:1883"
	topic := "dev/test"
	payload := "test message"
	qos := 1
	retain := false

	clientCfg := &client.ClientConfig{
		ClientID:       "test-client",
		RetryDelay:     10 * time.Second,
		RetryCount:     4,
		ConnectTimeout: 20 * time.Second,
		KeepAlive:      60 * time.Second,
		CleanSession:   true,
	}
	logger := util.NewDebugLogger("test")
	c := client.NewClient(logger, clientCfg)

	fmt.Printf("Connecting to a MQTT-SN broker %#v\n", brokerAddress)
	if err := c.Dial(brokerAddress); err != nil {
		panic(err)
	}
	if err := c.Connect(); err != nil {
		panic(err)
	}
	defer c.Disconnect()

	fmt.Printf("Registering topic %#v\n", topic)
	if err := c.Register(topic); err != nil {
		panic(err)
	}

	fmt.Printf("Publishing: %s <- %s\n", topic, string(payload))
	if err := c.Publish(topic, uint8(qos), retain, []byte(payload)); err != nil {
		panic(err)
	}

	fmt.Println("Everything OK")
}