From 33bdd93939ee58655939b67faea7356c26d952b6 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期二, 22 八月 2023 09:28:06 +0800
Subject: [PATCH] 消费消息时channel换成设备id
---
nsq/nsq.go | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
diff --git a/nsq/nsq.go b/nsq/nsq.go
index c4bdcf2..542f31f 100644
--- a/nsq/nsq.go
+++ b/nsq/nsq.go
@@ -17,7 +17,7 @@
}
safe.Go(func() {
- _ = Consume(fmt.Sprintf("aps.%v.scheduleTask", conf.Conf.NsqConf.NodeId), "sensor01")
+ _ = Consume(fmt.Sprintf("aps.%v.scheduleTask", conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
})
return nil
--
Gitblit v1.8.0