|
@@ -29,7 +29,7 @@ var (
|
|
|
|
|
|
// PrepareTimeWindowProducerQueue 负责监听所有主题并修改时间窗口
|
|
|
func PrepareTimeWindowProducerQueue() {
|
|
|
- log.GlobalLogger.Info("------- 主节点监听线程,启动!-------")
|
|
|
+ log.GlobalLogger.Info("订阅者 goroutine,启动。")
|
|
|
|
|
|
//创建订阅者0订阅主题 nodefault_info
|
|
|
log.GlobalLogger.Info("创建订阅者0订阅话题 ", masterConfig.TopicOfNodeFaultInfo)
|