root
/
ifishMQ
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

注释备注

This commit is contained in:
yiyan 2019-04-10 01:02:22 +08:00
parent f8ada962b3
commit 874d05f423
2 changed files with 14 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/com/ifish7/mq/mqtt/client/ClientMqttMessageListener.java
View File

@ -27,20 +27,4 @@ public class ClientMqttMessageListener implements SessionAwareMessageListener<By
log.error(e.getMessage(),e);
}
}
public String bytesToHexString(byte[] src){
StringBuilder stringBuilder = new StringBuilder();
if (src == null || src.length <= 0) {
return null;
}
for (int i = 0; i < src.length; i++) {
int v = src[i] & 0xFF;
String hv = Integer.toHexString(v);
if (hv.length() < 2) {
stringBuilder.append(0);
}
stringBuilder.append(hv);
}
return stringBuilder.toString();
}
}

14
src/main/java/com/ifish7/mq/queues/event/IntelligentHeatingRodEvent.java
View File

@ -20,6 +20,20 @@ public class IntelligentHeatingRodEvent extends EventSupport {
/**
* 智能加热棒新增或修改
* {
* "eventProcess": "intelligentHeatingRodSaveOrUpdate",
* "eventName": "com.ifish7.mq.queues.event.IntelligentHeatingRodEvent",
* "eventBody": {
* "entity" : "com.ifish7.mq.business.device.entity.TblDeviceHeater",
* "data" : {
* "heaterMacAddress": "12345",
* "heaterWaterTemperature": "12",
* "heaterPh": "800",
* "heaterGatheringTime": "08",
* "heaterGatheringDate": "2019-04-09"
* }
** }
* }
* @param eventBody
*/
public void intelligentHeatingRodSaveOrUpdate(String eventBody){