Package org.springframework.cloud.fn.supplier.mqtt

Class MqttSupplierConfiguration

java.lang.Object
org.springframework.cloud.fn.supplier.mqtt.MqttSupplierConfiguration
@Configuration(proxyBeanMethods=false) @EnableConfigurationProperties({MqttProperties.class,MqttSupplierProperties.class}) @Import(MqttConfiguration.class) public class MqttSupplierConfiguration extends Object
A source module that receives data from Mqtt.
Author:
Janne Valkealahti, Soby Chacko

  • Constructor Summary

    Constructors
    Constructor
    Description
    MqttSupplierConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
    mqttInbound(org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter> mqttMessageProducerCustomizer)
     
    org.reactivestreams.Publisher<Message<byte[]>>
    mqttPublisher(org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter mqttInbound)
     
    Supplier<reactor.core.publisher.Flux<Message<?>>>
    mqttSupplier(org.reactivestreams.Publisher<Message<?>> mqttPublisher)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MqttSupplierConfiguration

      public MqttSupplierConfiguration()

  • Method Details

    • mqttSupplier

      @Bean public Supplier<reactor.core.publisher.Flux<Message<?>>> mqttSupplier(org.reactivestreams.Publisher<Message<?>> mqttPublisher)

    • mqttInbound

      @Bean public org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter mqttInbound(@Nullable org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter> mqttMessageProducerCustomizer)

    • mqttPublisher

      @Bean public org.reactivestreams.Publisher<Message<byte[]>> mqttPublisher(org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter mqttInbound)