Package org.openwms.wms.app

Class InventoryAsyncConfiguration

java.lang.Object
org.openwms.wms.app.InventoryAsyncConfiguration
@Profile("ASYNCHRONOUS") @Configuration @RefreshScope @EnableRabbit class InventoryAsyncConfiguration extends Object
A InventoryAsyncConfiguration 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
     
    private static final String
    POISON_MESSAGE
     
    private static final String
    X_DEAD_LETTER_EXCHANGE
     
    private static final String
    X_DEAD_LETTER_ROUTING_KEY
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    InventoryAsyncConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) org.springframework.amqp.core.TopicExchange
    commonLgExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonTuCommandsExchange(String exchangeName)
     
    (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
    dlQueue(String queueName)
     
    (package private) org.springframework.amqp.core.Queue
    eventsLgQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.DirectExchange
    inventoryCommandsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.TopicExchange
    inventoryExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    lgBinding(org.springframework.amqp.core.TopicExchange commonLgExchange, org.springframework.amqp.core.Queue eventsLgQueue, String routingKey)
     
    (package private) org.springframework.amqp.support.converter.MessageConverter
    messageConverter()
     
    (package private) org.springframework.amqp.core.Binding
    movementBinding(org.springframework.amqp.core.TopicExchange movementExchange, org.springframework.amqp.core.Queue movementQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    movementExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    movementQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    puCommandsBinding(org.springframework.amqp.core.DirectExchange inventoryCommandsExchange, org.springframework.amqp.core.Queue puCommandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.Queue
    puCommandsQueue(String queueName, String exchangeName)
     
    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)
     
    (package private) org.springframework.amqp.core.Binding
    tuBinding(org.springframework.amqp.core.TopicExchange tuExchange, org.springframework.amqp.core.Queue tuQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.Binding
    tuCommandsBinding(org.springframework.amqp.core.TopicExchange commonTuCommandsExchange, org.springframework.amqp.core.Queue tuCommandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.Queue
    tuCommandsQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.TopicExchange
    tuExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    tuQueue(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

    • InventoryAsyncConfiguration

      InventoryAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

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

    • inventoryExchange

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

    • tuExchange

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

    • commonLgExchange

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

    • commonTuCommandsExchange

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

    • inventoryCommandsExchange

      @RefreshScope @Bean org.springframework.amqp.core.DirectExchange inventoryCommandsExchange(@Value("${owms.commands.inventory.exchange-name}") String exchangeName)

    • shippingExchange

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

    • movementExchange

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

    • tuQueue

      @Bean org.springframework.amqp.core.Queue tuQueue(@Value("${owms.events.inventory.tu.queue-name}") String queueName, @Value("${owms.dead-letter.exchange-name}") String exchangeName)

    • eventsLgQueue

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

    • tuCommandsQueue

      @Bean org.springframework.amqp.core.Queue tuCommandsQueue(@Value("${owms.commands.inventory.tu.queue-name}") String queueName, @Value("${owms.dead-letter.exchange-name}") String exchangeName)

    • puCommandsQueue

      @Bean org.springframework.amqp.core.Queue puCommandsQueue(@Value("${owms.commands.inventory.pu.queue-name}") String queueName, @Value("${owms.dead-letter.exchange-name}") String exchangeName)

    • shippingSplitQueue

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

    • movementQueue

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

    • tuBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding tuBinding(@Qualifier("tuExchange") org.springframework.amqp.core.TopicExchange tuExchange, @Qualifier("tuQueue") org.springframework.amqp.core.Queue tuQueue, @Value("${owms.events.inventory.tu.routing-key}") String routingKey)

    • lgBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding lgBinding(@Qualifier("commonLgExchange") org.springframework.amqp.core.TopicExchange commonLgExchange, @Qualifier("eventsLgQueue") org.springframework.amqp.core.Queue eventsLgQueue, @Value("${owms.events.inventory.lg.routing-key}") String routingKey)

    • tuCommandsBinding

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

    • puCommandsBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding puCommandsBinding(@Qualifier("inventoryCommandsExchange") org.springframework.amqp.core.DirectExchange inventoryCommandsExchange, @Qualifier("puCommandsQueue") org.springframework.amqp.core.Queue puCommandsQueue, @Value("${owms.commands.inventory.pu.routing-key}") String routingKey)

    • splitBinding

      @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)

    • movementBinding

      @RefreshScope @Bean org.springframework.amqp.core.Binding movementBinding(@Qualifier("movementExchange") org.springframework.amqp.core.TopicExchange movementExchange, @Qualifier("movementQueue") org.springframework.amqp.core.Queue movementQueue, @Value("${owms.events.movement.routing-key}") String routingKey)

    • dlExchange

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

    • dlQueue

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

    • dlBinding

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