From 85a33eab1eadf2edadae8108a579a9cf862bf81d Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 19 Dec 2024 15:01:01 -0500 Subject: [PATCH] Som code improvements in the `MqttSupplierConfiguration` --- .../cloud/fn/supplier/mqtt/MqttSupplierConfiguration.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/supplier/spring-mqtt-supplier/src/main/java/org/springframework/cloud/fn/supplier/mqtt/MqttSupplierConfiguration.java b/supplier/spring-mqtt-supplier/src/main/java/org/springframework/cloud/fn/supplier/mqtt/MqttSupplierConfiguration.java index 0045b64f..90e637cb 100644 --- a/supplier/spring-mqtt-supplier/src/main/java/org/springframework/cloud/fn/supplier/mqtt/MqttSupplierConfiguration.java +++ b/supplier/spring-mqtt-supplier/src/main/java/org/springframework/cloud/fn/supplier/mqtt/MqttSupplierConfiguration.java @@ -39,6 +39,7 @@ import org.springframework.messaging.Message; * * @author Janne Valkealahti * @author Soby Chacko + * @author Artem Bilan */ @EnableConfigurationProperties(MqttSupplierProperties.class) @AutoConfiguration(after = MqttConfiguration.class) @@ -58,7 +59,6 @@ public class MqttSupplierConfiguration { mqttClientFactory, properties.getTopics()); adapter.setQos(properties.getQos()); adapter.setConverter(pahoMessageConverter(properties, beanFactory)); - adapter.setAutoStartup(false); if (mqttMessageProducerCustomizer != null) { mqttMessageProducerCustomizer.customize(adapter); @@ -72,8 +72,9 @@ public class MqttSupplierConfiguration { return IntegrationFlow.from(mqttInbound).toReactivePublisher(true); } - private DefaultPahoMessageConverter pahoMessageConverter(MqttSupplierProperties properties, + private static DefaultPahoMessageConverter pahoMessageConverter(MqttSupplierProperties properties, BeanFactory beanFactory) { + DefaultPahoMessageConverter converter = new DefaultPahoMessageConverter(properties.getCharset()); converter.setPayloadAsBytes(properties.isBinary()); converter.setBeanFactory(beanFactory);