@EnableConfigurationProperties(value=RabbitSupplierProperties.class) public class RabbitSupplierConfiguration extends Object implements org.springframework.beans.factory.DisposableBean
Constructor and Description |
---|
RabbitSupplierConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter |
adapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container,
org.springframework.integration.channel.FluxMessageChannel channel) |
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer |
container() |
void |
destroy() |
org.springframework.integration.channel.FluxMessageChannel |
output() |
org.springframework.retry.interceptor.RetryOperationsInterceptor |
rabbitSourceRetryInterceptor() |
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> |
rabbitSupplier(org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter adapter,
org.springframework.integration.channel.FluxMessageChannel channel) |
@Bean public org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container()
@Bean public org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter adapter(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container, org.springframework.integration.channel.FluxMessageChannel channel)
@Bean public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> rabbitSupplier(org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter adapter, org.springframework.integration.channel.FluxMessageChannel channel)
@Bean public org.springframework.integration.channel.FluxMessageChannel output()
@Bean public org.springframework.retry.interceptor.RetryOperationsInterceptor rabbitSourceRetryInterceptor()
Copyright © 2020. All rights reserved.