|
|
@@ -260,9 +260,11 @@ public class OperationMessageService {
|
|
|
operationMessage.setTopic(topicName); // topic名称
|
|
|
operationMessage.setOperationType(OperationType.Sub);
|
|
|
operationMessage.setMessageClass(messageClass);
|
|
|
+ // 接收的mqtt数据
|
|
|
operationMessage.setData(jsonObject);
|
|
|
operationMessage.setTtlTime(ttl);
|
|
|
operationMessage.setSendTime(time);
|
|
|
+ // 数据ID
|
|
|
operationMessage.setDataId(id);
|
|
|
operationMessage.setIsTimeOut(isTimeOut);
|
|
|
operationMessage.setEvent(event);
|