Package org.openwms.wms.receiving.app

Class 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 org.slf4j.Logger BOOT_LOGGER  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      (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)  
      (package private) org.springframework.amqp.support.converter.MessageConverter messageConverter()  
      (package private) org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate​(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.support.converter.MessageConverter messageConverter)  
      (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)  

    • Field Detail

      • BOOT_LOGGER

        private static final org.slf4j.Logger BOOT_LOGGER

    • Constructor Detail

      • ReceivingAsyncConfiguration

        public ReceivingAsyncConfiguration()

    • Method Detail

      • 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

        @Bean
org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate​(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                                   org.springframework.amqp.support.converter.MessageConverter messageConverter)

      • tuExchange

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

      • tuQueue

        @Bean
org.springframework.amqp.core.Queue tuQueue​(@Value("${owms.events.common.tu.queue-name}")
                                            String queueName)

      • tuBinding

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

      • inventoryExchange

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

      • inventoryProductsQueue

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

      • inventoryProductsBinding

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