Mqtt: fix setter not cleared

GrimmiMeloni · Jul 18, 2023 · 4b4587a · 4b4587a
1 parent b0d2c2f
commit 4b4587a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/provider/mqtt/client.go b/provider/mqtt/client.go
@@ -137,7 +137,8 @@ func (m *Client) Listen(topic string, callback func(string)) {
 
 // ListenSetter creates a /set listener that resets the payload after handling
 func (m *Client) ListenSetter(topic string, callback func(string) error) {
-	m.Listen(topic+"/set", func(payload string) {
+	topic += "/set"
+	m.Listen(topic, func(payload string) {
 		if err := callback(payload); err != nil {
 			m.log.ERROR.Printf("set %s: %v", topic, err)
 		}