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	amqpMessageConverterWithEventSerializer(Serializer eventSerializer, RoutingKeyResolver routingKeyResolver)
AMQPMessageConverter	amqpMessageConverterWithGenericSerializer(Serializer serializer, 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()

amqpMessageConverterWithEventSerializer

@ConditionalOnMissingBean
 @ConditionalOnSingleCandidate(value=Serializer.class)
 @ConditionalOnQualifiedBean(beanClass=Serializer.class,
                            qualifier="eventSerializer")
 @Bean(value="amqpMessageConverter")
public AMQPMessageConverter amqpMessageConverterWithEventSerializer(@Qualifier(value="eventSerializer")
                                                                                                                                                                                                                                                                                                                 Serializer eventSerializer,
                                                                                                                                                                                                                                                                                                                 RoutingKeyResolver routingKeyResolver)

amqpMessageConverterWithGenericSerializer

@ConditionalOnMissingBean
 @ConditionalOnSingleCandidate(value=Serializer.class)
 @ConditionalOnMissingQualifiedBean(beanClass=Serializer.class,
                                   qualifier="eventSerializer")
 @Bean(value="amqpMessageConverter")
public AMQPMessageConverter amqpMessageConverterWithGenericSerializer(Serializer serializer,
                                                                                                                                                                                                                                                                                                                                 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)