Package org.springframework.cloud.fn.consumer.mqtt

Class MqttConsumerConfiguration

java.lang.Object
org.springframework.cloud.fn.consumer.mqtt.MqttConsumerConfiguration
@Configuration(proxyBeanMethods=false) @EnableConfigurationProperties({MqttProperties.class,MqttConsumerProperties.class}) @Import(MqttConfiguration.class) public class MqttConsumerConfiguration extends Object
A consumer that sends data to Mqtt.
Author:
Janne Valkealahti

  • Constructor Details

    • MqttConsumerConfiguration

      public MqttConsumerConfiguration()

  • Method Details

    • mqttConsumer

      @Bean public Consumer<Message<?>> mqttConsumer(MessageHandler mqttOutbound)

    • mqttOutbound

      @Bean public MessageHandler mqttOutbound(@Nullable org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler> mqttMessageHandlerCustomizer)

    • pahoMessageConverter

      public org.springframework.integration.mqtt.support.DefaultPahoMessageConverter pahoMessageConverter()