starter

yomo-rcvr-mqtt-starter

支持为YoMo-Edge进行Receiver的开发，在通过MQTT Broker对IoT发送的消息进行消费时，可以利用本组件方便对消息进行处理。

使用外部Broker

1. 使用场景

2. 例子代码

执行Sub(func(topic string, payload []byte){})

func CreateServer(addr string, writer io.Writer) {
	starter.NewBroker(&starter.BrokerConf{
		Addr:   addr,
		Topics: []string{"test"},
	}).Sub(func(topic string, payload []byte) {
		_, _ = writer.Write(starter.Pack(payload))
	})
}