org.springframework.cloud.stream.app.rabbit.sink

Class RabbitSinkConfiguration

java.lang.Object

org.springframework.cloud.stream.app.rabbit.sink.RabbitSinkConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean

@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
 @EnableConfigurationProperties(value=RabbitSinkProperties.class)
public class RabbitSinkConfiguration
extends Object
implements org.springframework.beans.factory.DisposableBean

A sink module that sends data to RabbitMQ.

Author:

Gary Russell, Chris Schaefer

Constructor Summary

Constructors

Constructor and Description
RabbitSinkConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageHandler	amqpChannelAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)
void	destroy()
org.springframework.amqp.support.converter.Jackson2JsonMessageConverter	jsonConverter()
org.springframework.amqp.rabbit.core.RabbitTemplate	rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitSinkConfiguration

public RabbitSinkConfiguration()

Method Detail

amqpChannelAdapter

@ServiceActivator(inputChannel="input")
 @Bean
public org.springframework.messaging.MessageHandler amqpChannelAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)
                                                                                                               throws Exception

Throws:

Exception

rabbitTemplate

@Bean
public org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)

jsonConverter

@Bean
 @ConditionalOnProperty(name="rabbit.converterBeanName",
                       havingValue="jsonConverter")
public org.springframework.amqp.support.converter.Jackson2JsonMessageConverter jsonConverter()

destroy

public void destroy()
             throws Exception

Specified by:

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

Throws:

Exception