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 org.slf4j.Logger
BOOT_LOGGER
-
Constructor Summary
Constructors Constructor Description ReceivingAsyncConfiguration()
-
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)
-
-
-
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)
-
-