org.springframework.cloud.stream.app.rabbit.source

Class RabbitSourceConfiguration

java.lang.Object

org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean

@EnableBinding(value=org.springframework.cloud.stream.messaging.Source.class)
 @EnableConfigurationProperties(value=RabbitSourceProperties.class)
public class RabbitSourceConfiguration
extends Object
implements org.springframework.beans.factory.DisposableBean

A source module that receives data from RabbitMQ.

Author:

Gary Russell, Chris Schaefer

Constructor Summary

Constructors

Constructor and Description
RabbitSourceConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter	adapter()
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer	container()
void	destroy()
org.springframework.retry.interceptor.RetryOperationsInterceptor	rabbitSourceRetryInterceptor()

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitSourceConfiguration

public RabbitSourceConfiguration()

Method Detail

container

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

Throws:

Exception

adapter

@Bean
public org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter adapter()
                                                                                     throws Exception

Throws:

Exception

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