Browse Source

性能优化--并行处理设备数据

pengdi@zoniot.com 4 years ago
parent
commit
aa1d45a968

+ 1 - 1
iot-data-processor/src/main/java/com/zcxk/zoniot/data/processor/listener/DeviceDataMessageBus.java

@@ -51,7 +51,7 @@ public class DeviceDataMessageBus implements InitializingBean {
         DeviceData data = mongoTemplate.findOne(query, DeviceData.class);
         asyncProcessDeviceDataService.asyncProcessDeviceData(data,deviceDataProcessors);
         try {
-            Thread.sleep(200L);
+            Thread.sleep(100L);
         } catch (InterruptedException e) {
             log.error("thread interrupt",e);
         }