org.springframework.cloud.fn.consumer.rabbit

Class RabbitConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.rabbit.RabbitConsumerConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean

@EnableConfigurationProperties(value=RabbitConsumerProperties.class)
 @Configuration
public class RabbitConsumerConfiguration
extends Object
implements org.springframework.beans.factory.DisposableBean

A configuration for RabbitMQ Consumer function. Uses a AmqpOutboundChannelAdapterSpec to save payload contents to RabbitMQ.

Author:

Soby Chako, Nicolas Labrot, Chris Bono

Constructor Summary

Constructors

Constructor and Description
RabbitConsumerConfiguration()

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()
Function<org.springframework.messaging.Message<?>,Object>	rabbitConsumer(org.springframework.messaging.MessageHandler messageHandler)
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

RabbitConsumerConfiguration

public RabbitConsumerConfiguration()

Method Detail

rabbitConsumer

@Bean
public Function<org.springframework.messaging.Message<?>,Object> rabbitConsumer(@Qualifier(value="amqpChannelAdapter")
                                                                                      org.springframework.messaging.MessageHandler messageHandler)

amqpChannelAdapter

@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()

Specified by:

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