Package org.openwms.tms.routing.app

Class RoutingAsyncConfiguration

java.lang.Object
org.openwms.tms.routing.app.RoutingAsyncConfiguration
@Profile("ASYNCHRONOUS") @EnableRabbit @Configuration public class RoutingAsyncConfiguration extends Object
A RoutingAsyncConfiguration is activated when the service uses asynchronous communication to access other services.
Author:
Heiko Scherrer

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    RoutingAsyncConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) org.springframework.amqp.core.Binding
    dlBinding(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.DirectExchange
    dlExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    dlq(String queueName)
     
    (package private) org.springframework.amqp.core.Binding
    lgBinding(org.springframework.amqp.core.TopicExchange lgExchange, org.springframework.amqp.core.Queue lgQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    lgExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    lgQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    locBinding(org.springframework.amqp.core.TopicExchange locExchange, org.springframework.amqp.core.Queue locQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    locExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    locQueue(String queueName, String exchangeName)
     
    (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.Binding
    tmsRequestsBinding(org.springframework.amqp.core.TopicExchange tmsRequestsExchange, org.springframework.amqp.core.Queue tmsRequestsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    tmsRequestsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    tmsRequestsQueue(String queueName, String exchangeName)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • RoutingAsyncConfiguration

      public RoutingAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

      @ConditionalOnExpression("\'${owms.routing.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)

    • tmsRequestsExchange

      @Bean org.springframework.amqp.core.TopicExchange tmsRequestsExchange(@Value("${owms.requests.routing.to.exchange-name}") String exchangeName)

    • tmsRequestsQueue

      @Bean org.springframework.amqp.core.Queue tmsRequestsQueue(@Value("${owms.requests.routing.to.queue-name}") String queueName, @Value("${owms.routing.dead-letter.exchange-name}") String exchangeName)

    • tmsRequestsBinding

      @Bean org.springframework.amqp.core.Binding tmsRequestsBinding(org.springframework.amqp.core.TopicExchange tmsRequestsExchange, org.springframework.amqp.core.Queue tmsRequestsQueue, @Value("${owms.requests.routing.to.routing-key}") String routingKey)

    • locExchange

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

    • locQueue

      @Bean org.springframework.amqp.core.Queue locQueue(@Value("${owms.events.common.loc.queue-name}") String queueName, @Value("${owms.routing.dead-letter.exchange-name}") String exchangeName)

    • locBinding

      @Bean org.springframework.amqp.core.Binding locBinding(org.springframework.amqp.core.TopicExchange locExchange, org.springframework.amqp.core.Queue locQueue, @Value("${owms.events.common.loc.routing-key}") String routingKey)

    • lgExchange

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

    • lgQueue

      @Bean org.springframework.amqp.core.Queue lgQueue(@Value("${owms.events.common.lg.queue-name}") String queueName, @Value("${owms.routing.dead-letter.exchange-name}") String exchangeName)

    • lgBinding

      @Bean org.springframework.amqp.core.Binding lgBinding(org.springframework.amqp.core.TopicExchange lgExchange, org.springframework.amqp.core.Queue lgQueue, @Value("${owms.events.common.lg.routing-key}") String routingKey)

    • dlExchange

      @Bean org.springframework.amqp.core.DirectExchange dlExchange(@Value("${owms.routing.dead-letter.exchange-name}") String exchangeName)

    • dlq

      @Bean org.springframework.amqp.core.Queue dlq(@Value("${owms.routing.dead-letter.queue-name}") String queueName)

    • dlBinding

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