소스 검색

补充提交

liuyaowen 1 년 전
부모
커밋
7cf8cc71a0
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/java/com/yunfeiyun/agmp/iots/device/serviceImp/BzyDeviceImpl.java

+ 1 - 1
src/main/java/com/yunfeiyun/agmp/iots/device/serviceImp/BzyDeviceImpl.java

@@ -123,7 +123,7 @@ public class BzyDeviceImpl extends DeviceAbstractImpl implements IBzyDevice {
             }
         }
 
-        MqttPublisher mqttPublisher = mqttManager.getPublisherByService(SERVICE_NAME);
+        MqttPublisher mqttPublisher = mqttManager.getPublisherByDevConnBid(SERVICE_NAME);
         mqttPublisher.publish(IotMqttConstant.YFBzyTopic.TOPIC_BZY_CMD_PREFIX + cmdModel.getIotDevice().getDevCode(), mqttMsgContent);
         mqttPublisher.publish(IotMqttConstant.YFBzyTopic.TOPIC_BZY_CMD_PREFIX_2 + cmdModel.getIotDevice().getDevCode(), mqttMsgContent);
         log.info("【孢子仪】发送指令完毕!");