Package org.openwms.wms.shipping.app

Class ShippingAsyncConfiguration

java.lang.Object
org.openwms.wms.shipping.app.ShippingAsyncConfiguration
@Profile("ASYNCHRONOUS") @EnableRabbit @Configuration public class ShippingAsyncConfiguration extends Object
A ShippingAsyncConfiguration 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
    ShippingAsyncConfiguration()
     

  • 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
    inventoryBinding(org.springframework.amqp.core.TopicExchange inventoryExchange, org.springframework.amqp.core.Queue inventoryProductsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    inventoryExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    inventoryPickingQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    inventoryProductsQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.support.converter.MessageConverter
    messageConverter()
     
    (package private) org.springframework.amqp.core.Binding
    orderBinding(org.springframework.amqp.core.TopicExchange orderExchange, org.springframework.amqp.core.Queue orderQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    orderExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    orderQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    pickingBinding(org.springframework.amqp.core.TopicExchange inventoryExchange, org.springframework.amqp.core.Queue inventoryPickingQueue, String routingKey)
     
    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()
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • ShippingAsyncConfiguration

      public ShippingAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

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

    • orderExchange

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

    • inventoryExchange

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

    • orderQueue

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

    • inventoryProductsQueue

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

    • inventoryPickingQueue

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

    • orderBinding

      @Bean org.springframework.amqp.core.Binding orderBinding(@Qualifier("orderExchange") org.springframework.amqp.core.TopicExchange orderExchange, @Qualifier("orderQueue") org.springframework.amqp.core.Queue orderQueue, @Value("${owms.shipping.orders.routing-key}") String routingKey)

    • inventoryBinding

      @Bean org.springframework.amqp.core.Binding inventoryBinding(@Qualifier("inventoryExchange") org.springframework.amqp.core.TopicExchange inventoryExchange, @Qualifier("inventoryProductsQueue") org.springframework.amqp.core.Queue inventoryProductsQueue, @Value("${owms.events.inventory.products.routing-key}") String routingKey)

    • pickingBinding

      @Bean org.springframework.amqp.core.Binding pickingBinding(@Qualifier("inventoryExchange") org.springframework.amqp.core.TopicExchange inventoryExchange, @Qualifier("inventoryPickingQueue") org.springframework.amqp.core.Queue inventoryPickingQueue, @Value("${owms.events.inventory.picking.routing-key}") String routingKey)

    • dlExchange

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

    • dlq

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

    • dlBinding

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