nsq/nsq.go
@@ -34,7 +34,6 @@ var topics = []string{ constvar.NsqTopicScheduleTask, constvar.NsqTopicSendPlcAddress, constvar.NsqTopicProcessParamsResponse, constvar.NsqTopicApsProcessParams, constvar.NsqTopicDeviceUpdate, constvar.NsqTopicPullDataResponse, @@ -73,7 +72,9 @@ if consumer, ok := value.(*nsqclient.NsqConsumer); ok { nsqclient.DestroyNsqConsumer(consumer) logx.Infof("try stop consumer, topic : %v", key) consumer = nil } return true }) }