Package org.openwms.common.app

Class CommonOptAsyncConfiguration

java.lang.Object
org.openwms.common.app.CommonOptAsyncConfiguration
@Profile("ASYNCHRONOUS") @Configuration @RefreshScope @EnableRabbit class CommonOptAsyncConfiguration extends Object
A CommonOptAsyncConfiguration contains the modules asynchronous configuration that is only active when Springs ASYNCHRONOUS profile is set.
Author:
Heiko Scherrer

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private static final org.slf4j.Logger
    BOOT_LOGGER
     
    static final String
    DEAD_LETTER_EXCHANGE
     
    static final String
    DEAD_LETTER_ROUTING_KEY
     
    static final String
    POISON_MESSAGE
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CommonOptAsyncConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) org.springframework.amqp.core.Binding
    commandsBinding(org.springframework.amqp.core.TopicExchange commonTuCommandsExchange, org.springframework.amqp.core.Queue commandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.Queue
    commandsQueue(String queueName, org.springframework.amqp.core.DirectExchange dlExchange)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonLocCommandsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    commonLocCommandsQueue(String queueName, org.springframework.amqp.core.DirectExchange dlExchange)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonLocRegistrationCommandsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    commonLocRegistrationCommandsQueue(String queueName, org.springframework.amqp.core.DirectExchange dlExchange)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonTuCommandsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonTuExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonTuTExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    dlBinding(String applicationName, String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.DirectExchange
    dlExchange(String applicationName, String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    dlQueue(String applicationName, String queueName)
     
    (package private) org.springframework.amqp.core.Binding
    locCommandsBinding(org.springframework.amqp.core.TopicExchange commonLocCommandsExchange, org.springframework.amqp.core.Queue commonLocCommandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.Binding
    locRegistrationCommandsBinding(org.springframework.amqp.core.TopicExchange commonLocRegistrationCommandsExchange, org.springframework.amqp.core.Queue commonLocRegistrationCommandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.support.converter.MessageConverter
    messageConverter()
     
    org.springframework.amqp.rabbit.core.RabbitTemplate
    rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.beans.factory.ObjectProvider<org.springframework.amqp.support.converter.MessageConverter> messageConverter, org.ameba.amqp.RabbitTemplateConfigurable rabbitTemplateConfigurable)
     
    (package private) org.springframework.amqp.support.converter.MessageConverter
    serializerMessageConverter()
     
    (package private) org.springframework.amqp.core.TopicExchange
    shippingExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    shippingSplitQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    splitBinding(org.springframework.amqp.core.TopicExchange shippingExchange, org.springframework.amqp.core.Queue shippingSplitQueue, String routingKey)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • CommonOptAsyncConfiguration

      CommonOptAsyncConfiguration()

  • Method Details

    • messageConverter

      @ConditionalOnExpression("\'${owms.common.serialization}\'==\'json\'") @Bean org.springframework.amqp.support.converter.MessageConverter messageConverter()

    • serializerMessageConverter

      @ConditionalOnExpression("\'${owms.common.serialization}\'==\'barray\'") @Bean org.springframework.amqp.support.converter.MessageConverter serializerMessageConverter()

    • rabbitTemplate

      @Primary @Bean(name="amqpTemplate") public org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.beans.factory.ObjectProvider<org.springframework.amqp.support.converter.MessageConverter> messageConverter, @Autowired(required=false) org.ameba.amqp.RabbitTemplateConfigurable rabbitTemplateConfigurable)

    • dlExchange

      @RefreshScope @Bean org.springframework.amqp.core.DirectExchange dlExchange(@Value("${spring.application.name}") String applicationName, @Value("${owms.dead-letter.exchange-name:}") String exchangeName)

    • commonTuExchange

      @RefreshScope @Bean org.springframework.amqp.core.TopicExchange commonTuExchange(@Value("${owms.events.common.tu.exchange-name}") String exchangeName)

    • commonTuTExchange

      @RefreshScope @Bean org.springframework.amqp.core.TopicExchange commonTuTExchange(@Value("${owms.events.common.tut.exchange-name}") String exchangeName)

    • commonTuCommandsExchange

      @RefreshScope @Bean org.springframework.amqp.core.TopicExchange commonTuCommandsExchange(@Value("${owms.commands.common.tu.exchange-name}") String exchangeName)

    • commonLocCommandsExchange

      @RefreshScope @Bean org.springframework.amqp.core.TopicExchange commonLocCommandsExchange(@Value("${owms.commands.common.loc.exchange-name}") String exchangeName)

    • commonLocRegistrationCommandsExchange

      @RefreshScope @Bean org.springframework.amqp.core.TopicExchange commonLocRegistrationCommandsExchange(@Value("${owms.commands.common.registration.exchange-name}") String exchangeName)

    • shippingExchange

      @Profile("SHIPPING") @RefreshScope @Bean org.springframework.amqp.core.TopicExchange shippingExchange(@Value("${owms.events.shipping.exchange-name}") String exchangeName)

    • dlQueue

      @RefreshScope @Bean org.springframework.amqp.core.Queue dlQueue(@Value("${spring.application.name}") String applicationName, @Value("${owms.dead-letter.queue-name:}") String queueName)

    • commandsQueue

      @RefreshScope @Bean org.springframework.amqp.core.Queue commandsQueue(@Value("${owms.commands.common.tu.queue-name}") String queueName, org.springframework.amqp.core.DirectExchange dlExchange)

    • commonLocCommandsQueue

      @RefreshScope @Bean org.springframework.amqp.core.Queue commonLocCommandsQueue(@Value("${owms.commands.common.loc.queue-name}") String queueName, org.springframework.amqp.core.DirectExchange dlExchange)

    • commonLocRegistrationCommandsQueue

      @RefreshScope @Bean org.springframework.amqp.core.Queue commonLocRegistrationCommandsQueue(@Value("${owms.commands.common.registration.queue-name}") String queueName, org.springframework.amqp.core.DirectExchange dlExchange)

    • shippingSplitQueue

      @Profile("SHIPPING") @RefreshScope @Bean org.springframework.amqp.core.Queue shippingSplitQueue(@Value("${owms.events.shipping.split.queue-name}") String queueName, @Value("${owms.dead-letter.exchange-name}") String exchangeName)

    • dlBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding dlBinding(@Value("${spring.application.name}") String applicationName, @Value("${owms.dead-letter.queue-name:}") String queueName, @Value("${owms.dead-letter.exchange-name:}") String exchangeName)

    • commandsBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding commandsBinding(@Qualifier("commonTuCommandsExchange") org.springframework.amqp.core.TopicExchange commonTuCommandsExchange, @Qualifier("commandsQueue") org.springframework.amqp.core.Queue commandsQueue, @Value("${owms.commands.common.tu.routing-key}") String routingKey)

    • locCommandsBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding locCommandsBinding(@Qualifier("commonLocCommandsExchange") org.springframework.amqp.core.TopicExchange commonLocCommandsExchange, @Qualifier("commonLocCommandsQueue") org.springframework.amqp.core.Queue commonLocCommandsQueue, @Value("${owms.commands.common.loc.routing-key}") String routingKey)

    • locRegistrationCommandsBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding locRegistrationCommandsBinding(@Qualifier("commonLocRegistrationCommandsExchange") org.springframework.amqp.core.TopicExchange commonLocRegistrationCommandsExchange, @Qualifier("commonLocRegistrationCommandsQueue") org.springframework.amqp.core.Queue commonLocRegistrationCommandsQueue, @Value("${owms.commands.common.registration.routing-key}") String routingKey)

    • splitBinding

      @Profile("SHIPPING") @RefreshScope @Bean org.springframework.amqp.core.Binding splitBinding(@Qualifier("shippingExchange") org.springframework.amqp.core.TopicExchange shippingExchange, @Qualifier("shippingSplitQueue") org.springframework.amqp.core.Queue shippingSplitQueue, @Value("${owms.events.shipping.split.routing-key}") String routingKey)