|
|
@@ -129,7 +129,7 @@ func (c *MqttClient) GetRouter(group string, handlers []router.Handler) *router.
|
|
|
}
|
|
|
|
|
|
err := item.DoIfUnSubscribe(func() error {
|
|
|
- token := c.client.Subscribe(item.Topic, item.Qos, func(client mqtt.Client, message mqtt.Message) {
|
|
|
+ token := c.client.Subscribe(item.Topic, 2, func(client mqtt.Client, message mqtt.Message) {
|
|
|
item.CallHandlers(message.Payload())
|
|
|
})
|
|
|
if token.Wait(); token.Error() != nil {
|
|
|
@@ -151,7 +151,7 @@ func (c *MqttClient) GetRouter(group string, handlers []router.Handler) *router.
|
|
|
}
|
|
|
|
|
|
func (c *MqttClient) Response(item *router.Item, data []byte) error {
|
|
|
- token := c.client.Publish(item.Topic+"/reply", item.Qos, false, data)
|
|
|
+ token := c.client.Publish(item.Topic+"/reply", 2, false, data)
|
|
|
if token.Wait(); token.Error() != nil {
|
|
|
return token.Error()
|
|
|
}
|
|
|
@@ -163,7 +163,7 @@ func (c *MqttClient) onConnect() error {
|
|
|
err := c.rangeRouters(func(r *router.Router) error {
|
|
|
err := r.RangeItem(func(item *router.Item) error {
|
|
|
err := item.DoIfUnSubscribe(func() error {
|
|
|
- token := c.client.Subscribe(item.Topic, item.Qos, func(client mqtt.Client, message mqtt.Message) {
|
|
|
+ token := c.client.Subscribe(item.Topic, 2, func(client mqtt.Client, message mqtt.Message) {
|
|
|
item.CallHandlers(message.Payload())
|
|
|
})
|
|
|
if token.Wait(); token.Error() != nil {
|