|
@@ -28,7 +28,6 @@ var (
|
|
|
// PrepareTimeWindowProducerQueue 负责监听所有主题并修改时间窗口
|
|
// PrepareTimeWindowProducerQueue 负责监听所有主题并修改时间窗口
|
|
|
func PrepareTimeWindowProducerQueue() {
|
|
func PrepareTimeWindowProducerQueue() {
|
|
|
c_log.GlobalLogger.Info("订阅者 goroutine，启动。")
|
|
c_log.GlobalLogger.Info("订阅者 goroutine，启动。")
|
|
|
- c_log.GlobalLogger.Info("创建订阅者订阅话题 ", masterConfig.TopicOfCicvLocation)
|
|
|
|
|
|
|
|
|
|
var err error
|
|
var err error
|
|
|
subscribers := make([]*goroslib.Subscriber, len(commonConfig.SubscribeTopics))
|
|
subscribers := make([]*goroslib.Subscriber, len(commonConfig.SubscribeTopics))
|
孟令鑫