README ¶
MQTT Broker
The MQTT broker is useful for IoT based applications
Usage
Drop in import
import _ "github.com/micro/go-plugins/broker/mqtt"
Flag on command line
go run main.go --broker=mqtt
Alternatively use directly
import (
"github.com/micro/go-micro"
"github.com/micro/go-plugins/broker/mqtt"
)
func main() {
service := micro.NewService(
micro.Name("my.service"),
micro.Broker(mqtt.NewBroker()),
)
}
Encoding
Because MQTT does not support message headers the plugin encodes messages using JSON.
If you prefer to send and receive the mqtt payload uninterpreted use the noop
codec.
Example
import (
"github.com/micro/broker"
"github.com/micro/broker/codec/noop"
"github.com/micro/go-plugins/broker/mqtt"
)
b := mqtt.NewBroker(
broker.Codec(noop.NewCodec()),
)
Documentation ¶
Click to show internal directories.
Click to hide internal directories.