fix(mqttd): redis key expired

sb-im · Mar 21, 2023 · d04dd12 · d04dd12
1 parent 565955c
commit d04dd12
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/mqttd/mqttd.go b/mqttd/mqttd.go
@@ -210,10 +210,14 @@ func (t *Mqtt) Run(ctx context.Context) {
 			fmt.Sprintf(keyspace, "nodes/*"),
 			fmt.Sprintf(keyspace, "tasks/*"),
 		).Channel()
+
 		for {
 			select {
 			case m := <-ch:
 				log.Debugf("%s: message: %s\n", m.Channel, m.Payload)
+				if m.Payload != "set" {
+					continue
+				}
 
 				// topic:
 				// plans/1/running
@@ -224,6 +228,7 @@ func (t *Mqtt) Run(ctx context.Context) {
 				raw, err := data.Bytes()
 				if err != nil {
 					log.Error(err)
+					continue
 				}
 
 				// prefix: