@Configuration @EnableConfigurationProperties(value={MqttProperties.class,MqttSupplierProperties.class}) @Import(value=MqttConfiguration.class) public class MqttSupplierConfiguration extends Object
Constructor and Description |
---|
MqttSupplierConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter |
mqttInbound() |
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> |
mqttSupplier() |
org.springframework.integration.channel.FluxMessageChannel |
output() |
org.springframework.integration.mqtt.support.DefaultPahoMessageConverter |
pahoMessageConverter(org.springframework.beans.factory.BeanFactory beanFactory) |
@Bean public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> mqttSupplier()
@Bean public org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter mqttInbound()
@Bean public org.springframework.integration.channel.FluxMessageChannel output()
public org.springframework.integration.mqtt.support.DefaultPahoMessageConverter pahoMessageConverter(org.springframework.beans.factory.BeanFactory beanFactory)
Copyright © 2020. All rights reserved.