@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) @EnableConfigurationProperties(value=RabbitSinkProperties.class) public class RabbitSinkConfiguration extends Object
Constructor and Description |
---|
RabbitSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.messaging.MessageHandler |
amqpChannelAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory) |
org.springframework.amqp.support.converter.Jackson2JsonMessageConverter |
jsonConverter() |
org.springframework.amqp.rabbit.core.RabbitTemplate |
rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory) |
@ServiceActivator(inputChannel="input") @Bean public org.springframework.messaging.MessageHandler amqpChannelAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)
@Bean public org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)
@Bean @ConditionalOnProperty(name="rabbit.converterBeanName", havingValue="jsonConverter") public org.springframework.amqp.support.converter.Jackson2JsonMessageConverter jsonConverter()
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.