mqtt

Documentation

Overview

Package mqtt implements a stub that can replace the inbuilt Jeebus MQTTServer to allow a remote (out of process) MQTT Broker like RabbitMQ or Mosquitto to be used. This Gadget does NOT implement this remote broker, rather it checks for the remote host/port is listening and passes its input (Port) parameter through and steps out the way.

This can be useful if you want features that are not within the inbuilt MQTT Server, or you have additional external processes that want to share the MQTT broker that your jeebus app is using.

Usage: (just add to your imports in main.go) - it will override the default core MQTTServer.

_ "github.com/TheDistractor/flow-ext/gadgets/network/mqtt/compat"  //override the default server
_ "github.com/TheDistractor/flow-ext/gadgets/network/mqtt/mqttex"  //to provide a direct MQTTServerEx

Index

• type RemoteMQTTServer
  • func (w *RemoteMQTTServer) Run()

Types

type RemoteMQTTServer

type RemoteMQTTServer struct {
	flow.Gadget
	Port    flow.Input
	PortOut flow.Output
}

Our MQTTServer is really just a gated check for a remote MQTT Broker. because we pull in the original jeebus package, we make sure its init() runs before this one this then allows us to overwrite the MQTTServer before its used

func (*RemoteMQTTServer) Run

func (w *RemoteMQTTServer) Run()

Start the MQTT server.