Package org.openwms.transactions.app

Class TransactionAsyncConfiguration

java.lang.Object

org.openwms.transactions.app.TransactionAsyncConfiguration

@Profile("AMQP")
@EnableRabbit
@Configuration
class TransactionAsyncConfiguration
extends Object

A TransactionAsyncConfiguration is activated when the service uses asynchronous AMQP 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
TransactionAsyncConfiguration()

Method Summary

Modifier and Type	Method	Description
(package private) org.springframework.amqp.core.Binding	commandsBinding(org.springframework.amqp.core.TopicExchange transactionCommandsExchange, org.springframework.amqp.core.Queue commandsQueue, String routingKey)
(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.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.TopicExchange	transactionCommandsExchange(String exchangeName)
(package private) org.springframework.amqp.core.TopicExchange	transactionEventsExchange(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

TransactionAsyncConfiguration

TransactionAsyncConfiguration()

Method Details

messageConverter

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

serializerMessageConverter

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

transactionEventsExchange

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

transactionCommandsExchange

@Bean
org.springframework.amqp.core.TopicExchange transactionCommandsExchange(@Value("${owms.commands.transactions.tx.exchange-name}")
 String exchangeName)

commandsQueue

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

commandsBinding

@Bean
org.springframework.amqp.core.Binding commandsBinding(@Qualifier("transactionCommandsExchange")
 org.springframework.amqp.core.TopicExchange transactionCommandsExchange,
 @Qualifier("commandsQueue")
 org.springframework.amqp.core.Queue commandsQueue,
 @Value("${owms.commands.transactions.tx.routing-key}")
 String routingKey)

dlExchange

@Bean
org.springframework.amqp.core.DirectExchange dlExchange(@Value("${owms.transactions.dead-letter.exchange-name}")
 String exchangeName)

dlq

@Bean
org.springframework.amqp.core.Queue dlq(@Value("${owms.transactions.dead-letter.queue-name}")
 String queueName)

dlBinding

@Bean
org.springframework.amqp.core.Binding dlBinding(@Value("${owms.transactions.dead-letter.queue-name}")
 String queueName,
 @Value("${owms.transactions.dead-letter.exchange-name}")
 String exchangeName)