Package org.openwms.wms.movements.app

Class MovementAsyncConfiguration

java.lang.Object

org.openwms.wms.movements.app.MovementAsyncConfiguration

@Profile("ASYNCHRONOUS")
@EnableRabbit
@RefreshScope
@Configuration
class MovementAsyncConfiguration
extends Object

A MovementAsyncConfiguration contains the modules asynchronous configuration that is always active.

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
MovementAsyncConfiguration()

Method Summary

Modifier and Type	Method	Description
(package private) org.springframework.amqp.core.Binding	commandsBinding(org.springframework.amqp.core.DirectExchange commandsExchange, org.springframework.amqp.core.Queue commandsQueue, String routingKey)
(package private) org.springframework.amqp.core.DirectExchange	commandsExchange(String exchangeName)
(package private) org.springframework.amqp.core.Queue	commandsQueue(String queueName, String exchangeName)
(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.support.converter.MessageConverter	messageConverter()
(package private) org.springframework.amqp.core.TopicExchange	movementExchange(String exchangeName)
(package private) org.springframework.amqp.core.Binding	orderBinding(org.springframework.amqp.core.TopicExchange shippingExchange, org.springframework.amqp.core.Queue splitQueue, 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()
(package private) org.springframework.amqp.core.TopicExchange	shippingExchange(String exchangeName)
(package private) org.springframework.amqp.core.Queue	splitQueue(String queueName, String exchangeName)
(package private) org.springframework.amqp.core.TopicExchange	tuCommandsExchange(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:

• Constant Field Values

Constructor Details

MovementAsyncConfiguration

MovementAsyncConfiguration()

Method Details

messageConverter

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

serializerMessageConverter

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

tuCommandsExchange

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

movementExchange

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

commandsExchange

@Bean
org.springframework.amqp.core.DirectExchange commandsExchange(@Value("${owms.commands.movements.exchange-name}")
 String exchangeName)

shippingExchange

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

splitQueue

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

commandsQueue

@Bean
org.springframework.amqp.core.Queue commandsQueue(@Value("${owms.commands.movements.movement.queue-name}")
 String queueName,
 @Value("${owms.dead-letter.exchange-name}")
 String exchangeName)

orderBinding

@Bean
org.springframework.amqp.core.Binding orderBinding(@Qualifier("shippingExchange")
 org.springframework.amqp.core.TopicExchange shippingExchange,
 @Qualifier("splitQueue")
 org.springframework.amqp.core.Queue splitQueue,
 @Value("${owms.events.shipping.split.routing-key}")
 String routingKey)

commandsBinding

@Bean
org.springframework.amqp.core.Binding commandsBinding(@Qualifier("commandsExchange")
 org.springframework.amqp.core.DirectExchange commandsExchange,
 @Qualifier("commandsQueue")
 org.springframework.amqp.core.Queue commandsQueue,
 @Value("${owms.commands.movements.movement.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)