Package org.openwms.wms.receiving.app

Class ReceivingAsyncConfiguration

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReceivingAsyncConfiguration()
     

  • 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.TopicExchange
    inventoryExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    inventoryProductsBinding(org.springframework.amqp.core.TopicExchange inventoryExchange, org.springframework.amqp.core.Queue inventoryProductsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.Queue
    inventoryProductsQueue(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.core.TopicExchange
    receivingExchange(String exchangeName)
     
    (package private) org.springframework.amqp.support.converter.MessageConverter
    serializerMessageConverter()
     
    (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.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

    • BOOT_LOGGER

      private static final org.slf4j.Logger BOOT_LOGGER

    • POISON_MESSAGE

      private static final String POISON_MESSAGE
      See Also:

  • Constructor Details

    • ReceivingAsyncConfiguration

      public ReceivingAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

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

    • tuExchange

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

    • inventoryExchange

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

    • receivingExchange

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

    • tuQueue

      @Bean org.springframework.amqp.core.Queue tuQueue(@Value("${owms.events.common.tu.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)

    • tuBinding

      @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.common.tu.routing-key}") String routingKey)

    • inventoryProductsBinding

      @Bean org.springframework.amqp.core.Binding inventoryProductsBinding(@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)

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