@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) @EnableConfigurationProperties(value=RabbitSinkProperties.class) public class RabbitSinkConfiguration extends Object implements org.springframework.beans.factory.DisposableBean
Constructor and Description |
---|
RabbitSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
org.springframework.messaging.MessageHandler |
amqpChannelAdapter(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory) |
void |
destroy() |
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) throws Exception
Exception
@Bean public org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory rabbitConnectionFactory)
public void destroy()
destroy
in interface org.springframework.beans.factory.DisposableBean
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.