Skip to content

Y
YeeAmosFireAutoSysRoot
Commit 606d1f52 authored by 田涛's avatar 田涛
Browse files
Options

代码合并

parent b45bd842
Show whitespace changes
Inline Side-by-side
Showing with 0 additions and 3 deletions
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/ContingencyPlanServiceImpl.java
View file @ 606d1f52
...@@ -558,7 +558,6 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService { ...@@ -558,7 +558,6 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
public void subscribeTopic() { public void subscribeTopic() {
try { try {
emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_DOC, (s, mqttMessage) -> { emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_DOC, (s, mqttMessage) -> {
System.out.println(s);
byte[] payload = mqttMessage.getPayload(); byte[] payload = mqttMessage.getPayload();
try { try {
List<Long> ids = (List<Long>) ClazzUtils.deserializableObject(payload); List<Long> ids = (List<Long>) ClazzUtils.deserializableObject(payload);
...@@ -574,7 +573,6 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService { ...@@ -574,7 +573,6 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
} }
try { try {
emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_RULE, (s, mqttMessage) -> { emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_RULE, (s, mqttMessage) -> {
System.out.println(s);
byte[] payload = mqttMessage.getPayload(); byte[] payload = mqttMessage.getPayload();
try { try {
List<String> ids = (List<String>) ClazzUtils.deserializableObject(payload); List<String> ids = (List<String>) ClazzUtils.deserializableObject(payload);
...@@ -590,7 +588,6 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService { ...@@ -590,7 +588,6 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
} }
/*try { /*try {
emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_EQUIP, (s, mqttMessage) -> { emqKeeper.getMqttClient().subscribe(DELETE_SYNC_PLAN_EQUIP, (s, mqttMessage) -> {
System.out.println(s);
byte[] payload = mqttMessage.getPayload(); byte[] payload = mqttMessage.getPayload();
try { try {
List<Long> ids = (List<Long>) ClazzUtils.deserializableObject(payload); List<Long> ids = (List<Long>) ClazzUtils.deserializableObject(payload);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment