소스 검색

add
mqtt信息发送

lifang 3 주 전
부모
커밋
a8a64195e0
1개의 변경된 파일3개의 추가작업 그리고 0개의 파일을 삭제
  1. 3 0
      nb-core/src/main/java/com/nb/core/config/MqttConfig.java

+ 3 - 0
nb-core/src/main/java/com/nb/core/config/MqttConfig.java

@@ -27,6 +27,9 @@ public class MqttConfig {
     @Bean
     @ConditionalOnBean(MqttProperties.class)
     public MqttPahoClientFactory mqttClientFactory(MqttProperties mqttProperties) {
+        if(mqttProperties==null||mqttProperties.getBroker()==null){
+            return null;
+        }
         DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
         MqttConnectOptions options = new MqttConnectOptions();
         options.setServerURIs(new String[]{mqttProperties.getBroker().getUrl()});