|
|
@@ -40,7 +40,7 @@ public class MqttConfig {
|
|
|
@Value("${mqtt.broker:tcp://8.130.28.21:1883}")
|
|
|
private String serverUri;
|
|
|
|
|
|
- @Value("${mqtt.client.id:hfln-device-service}")
|
|
|
+ @Value("${mqtt.client-id}")
|
|
|
private String clientId;
|
|
|
|
|
|
@Value("${mqtt.username:admin}")
|
|
|
@@ -120,7 +120,7 @@ public class MqttConfig {
|
|
|
};
|
|
|
|
|
|
MqttPahoMessageDrivenChannelAdapter adapter =
|
|
|
- new MqttPahoMessageDrivenChannelAdapter(clientId + "_das", mqttClientFactory(), topics);
|
|
|
+ new MqttPahoMessageDrivenChannelAdapter(clientId, mqttClientFactory(), topics);
|
|
|
adapter.setCompletionTimeout(5000);
|
|
|
adapter.setConverter(new DefaultPahoMessageConverter());
|
|
|
adapter.setQos(2, 2, 0, 0, 0);
|