|
@@ -226,11 +226,12 @@ public class OperationMessageService {
|
|
|
event = arr[arr.length - 1];
|
|
event = arr[arr.length - 1];
|
|
|
jsonObject.put("event", event);
|
|
jsonObject.put("event", event);
|
|
|
}
|
|
}
|
|
|
- if (event.equals("ping")) {
|
|
|
|
|
- return;
|
|
|
|
|
- }
|
|
|
|
|
|
|
|
|
|
log.info("Topic: {}", topicName);
|
|
log.info("Topic: {}", topicName);
|
|
|
|
|
+// if (event.equals("ping")) {
|
|
|
|
|
+// return;
|
|
|
|
|
+// }
|
|
|
|
|
+
|
|
|
String gateWayId = jsonObject.getStr("gatewayId");
|
|
String gateWayId = jsonObject.getStr("gatewayId");
|
|
|
String deviceId = jsonObject.getStr("deviceId");
|
|
String deviceId = jsonObject.getStr("deviceId");
|
|
|
boolean isTimeOut = false;
|
|
boolean isTimeOut = false;
|