update...

潘钊
1 parent 1de463e6
Showing 1 changed file with 12 additions and 0 deletions
src/main/java/com/bsth/controller/realcontrol/anomalyCheckController.java
 package com.bsth.controller.realcontrol;
  
 import com.bsth.data.gpsdata.arrival.GpsRealAnalyse;
+import com.bsth.data.msg_queue.DirectivePushQueue;
+import com.bsth.data.msg_queue.WebSocketPushQueue;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
 import org.slf4j.Logger;
@@ -55,4 +57,14 @@ public class anomalyCheckController {
     public void shutdownThreadPool(){
         GpsRealAnalyse.shutdown();
     }
+
+    @RequestMapping(value = "/directivePushQueue")
+    public void directivePushQueue(){
+        DirectivePushQueue.start();
+    }
+
+    @RequestMapping(value = "/webSocketPushQueue")
+    public void webSocketPushQueue(){
+        WebSocketPushQueue.start();
+    }
 }