|
@@ -34,7 +34,7 @@ func RunTimeWindowProducerQueue() {
|
|
|
time.Sleep(time.Duration(1) * time.Second)
|
|
|
if len(entity.TimeWindowProducerQueue) > 0 {
|
|
|
|
|
|
- commonService.ChannelKillRosRecord <- 1
|
|
|
+ commonService.ChannelKillRosRecord <- 3
|
|
|
|
|
|
bags, _ := util.ListAbsolutePathWithSuffixAndSort(commonConfig.CloudConfig.BagDataDir, ".bag")
|
|
|
currentTimeWindow := entity.TimeWindowProducerQueue[0]
|