|
@@ -91,7 +91,7 @@ public class RabbitMqListener {
|
|
|
}
|
|
}
|
|
|
device.setClassification(deviceClient.getClassification(device.getDeviceId()));
|
|
device.setClassification(deviceClient.getClassification(device.getDeviceId()));
|
|
|
device.setDataNumber(deviceClient.nextDataNumber(device.getDeviceId()));
|
|
device.setDataNumber(deviceClient.nextDataNumber(device.getDeviceId()));
|
|
|
- iotMsgHandler.async(device,device.getDeviceId());
|
|
|
|
|
|
|
+ iotMsgHandler.sync(device,device.getDeviceId());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
private BusDeviceEntity createDevice( BusDeviceRunningEntity source ){
|
|
private BusDeviceEntity createDevice( BusDeviceRunningEntity source ){
|