|
|
@@ -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()});
|