Package org.openwms.common.comm.app

Class AsyncConfiguration

java.lang.Object

org.openwms.common.comm.app.AsyncConfiguration

@Profile("ASYNCHRONOUS")
@Configuration
@EnableRabbit
class AsyncConfiguration
extends Object

A AsyncConfiguration.

Author:

Heiko Scherrer

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	BOOT_LOGGER

Constructor Summary

Constructors

Constructor	Description
AsyncConfiguration()

Method Summary

Modifier and Type	Method	Description
(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.core.Binding	DLQbinding(String queueName, String exchangeName)
(package private) org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor	interceptor()
(package private) org.springframework.amqp.support.converter.MessageConverter	messageConverter()
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()

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

Constructor Details

AsyncConfiguration

AsyncConfiguration()

Method Details

messageConverter

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

serializerMessageConverter

@ConditionalOnExpression("\'${owms.driver.serialization}\'==\'barray\'")
@Bean
org.springframework.amqp.support.converter.MessageConverter serializerMessageConverter()

interceptor

@Bean
org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor interceptor()

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)

dlExchange

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

dlq

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

DLQbinding

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