|
|
|
@ -218,7 +218,7 @@ class MqttConsumer { |
|
|
|
} |
|
|
|
|
|
|
|
adapter.setCompletionTimeout(5000); |
|
|
|
adapter.setRecoveryInterval(5000); |
|
|
|
// adapter.set(5000);
|
|
|
|
adapter.setConverter(new DefaultPahoMessageConverter()); |
|
|
|
if (!Objects.nonNull(config.getQos())){ |
|
|
|
adapter.setQos(1); |
|
|
|
|