Fix QoS/Retain in paho wrapper (#53)

at-wat · Dec 26, 2019 · de91013 · de91013
1 parent 8d4ca17
commit de91013
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/paho/paho.go b/paho/paho.go
@@ -240,6 +240,8 @@ func (c *pahoWrapper) Publish(topic string, qos byte, retained bool, payload int
 			context.Background(),
 			&mqtt.Message{
 				Topic:   topic,
+				QoS:     mqtt.QoS(qos),
+				Retain:  retained,
 				Payload: p,
 			},
 		)