org.axonframework.boot.autoconfig

Class AMQPAutoConfiguration

java.lang.Object

org.axonframework.boot.autoconfig.AMQPAutoConfiguration

@Configuration
 @ConditionalOnClass(value=SpringAMQPPublisher.class)
 @EnableConfigurationProperties(value=AMQPProperties.class)
public class AMQPAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor and Description
AMQPAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
SpringAMQPPublisher	amqpBridge(EventBus eventBus, org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AMQPMessageConverter amqpMessageConverter)
AMQPMessageConverter	amqpMessageConverter(Serializer eventSerializer, RoutingKeyResolver routingKeyResolver)
RoutingKeyResolver	routingKeyResolver()

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPAutoConfiguration

public AMQPAutoConfiguration()

Method Detail

routingKeyResolver

@ConditionalOnMissingBean
 @Bean
public RoutingKeyResolver routingKeyResolver()

amqpMessageConverter

@ConditionalOnMissingBean
 @Bean
public AMQPMessageConverter amqpMessageConverter(@Qualifier(value="eventSerializer")
                                                                                    Serializer eventSerializer,
                                                                                    RoutingKeyResolver routingKeyResolver)

amqpBridge

@ConditionalOnProperty(value="axon.amqp.exchange")
 @ConditionalOnBean(value=org.springframework.amqp.rabbit.connection.ConnectionFactory.class)
 @ConditionalOnMissingBean
 @Bean(initMethod="start",
      destroyMethod="shutDown")
public SpringAMQPPublisher amqpBridge(EventBus eventBus,
                                                                                                                                                                                                                                                                                  org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                                                                                                                                                                                                                                                  AMQPMessageConverter amqpMessageConverter)