|
@@ -43,9 +43,9 @@ func main() {
|
|
|
|
|
|
|
|
|
|
go commonService.BagRecord(commonConfig.CloudConfig.Hosts[0].Name)
|
|
go commonService.BagRecord(commonConfig.CloudConfig.Hosts[0].Name)
|
|
-
|
|
+
|
|
go masterService.ProduceWindow()
|
|
go masterService.ProduceWindow()
|
|
-
|
|
+
|
|
go masterService.RunTimeWindowProducerQueue()
|
|
go masterService.RunTimeWindowProducerQueue()
|
|
|
|
|
|
go commonService.RunTimeWindowConsumerQueue()
|
|
go commonService.RunTimeWindowConsumerQueue()
|