mqtt

README

MQTT Broker

The MQTT broker is useful for IoT based applications

Usage

Drop in import

import _ "github.com/geiqin/go-plugins/broker/mqtt"

Flag on command line

go run main.go --broker=mqtt

Alternatively use directly

import (
	"github.com/geiqin/go-micro"
	"github.com/geiqin/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/geiqin/go-plugins/broker/mqtt"
)

b := mqtt.NewBroker(
    broker.Codec(noop.NewCodec()),
)

Documentation

Overview

Package mqtt provides an mqtt broker

Index

• func NewBroker(opts ...broker.Option) broker.Broker

Functions

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker