io.pivotal.java.function.rabbit.consumer

Class RabbitConsumerConfiguration

java.lang.Object

io.pivotal.java.function.rabbit.consumer.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

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()
             throws Exception

Specified by:

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

Throws:

Exception