org.springframework.cloud.fn.supplier.rabbit

Class RabbitSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.rabbit.RabbitSupplierConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean

@EnableConfigurationProperties(value=RabbitSupplierProperties.class)
public class RabbitSupplierConfiguration
extends Object
implements org.springframework.beans.factory.DisposableBean

A source module that receives data from RabbitMQ.

Author:

Gary Russell, Chris Schaefer, Roger Perez, Chris Bono

Constructor Summary

Constructors

Constructor and Description
RabbitSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer	container()
void	destroy()
org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>	rabbitPublisher(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container)
org.springframework.retry.interceptor.RetryOperationsInterceptor	rabbitSourceRetryInterceptor()
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>>>	rabbitSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> rabbitPublisher, org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter adapter)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitSupplierConfiguration

public RabbitSupplierConfiguration()

Method Detail

container

@Bean
public org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container()

rabbitPublisher

@Bean
public org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> rabbitPublisher(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container)

rabbitSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<byte[]>>> rabbitSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> rabbitPublisher,
                                                                                                                 org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter adapter)

rabbitSourceRetryInterceptor

@Bean
public org.springframework.retry.interceptor.RetryOperationsInterceptor rabbitSourceRetryInterceptor()

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception