iothubmqtt

type Config struct {
	Broker   string
	Port     int
	ClientID string
	Username string
	Password string
}

type MQTTClient interface {
	Configure()
	OnConnect(func(mqtt.Client))
	OnConnectionLost(func(mqtt.Client, error))
	Connect() error
	IsConnected() bool
	Configuration() Config

	Publish(topic, message string) error
	Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token
}