SpringCloud/spring-functions-catalog
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Som code improvements in the MqttSupplierConfiguration

Browse Source
This commit is contained in:
Artem Bilan
2024-12-19 15:01:01 -05:00
parent 6d4cb43c82
commit 85a33eab1e
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
supplier/spring-mqtt-supplier/src/main/java/org/springframework/cloud/fn/supplier/mqtt/MqttSupplierConfiguration.java
View File

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