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)