Package org.openwms.common.tasks.app

Class TaskAsyncConfiguration

java.lang.Object
org.openwms.common.tasks.app.TaskAsyncConfiguration
@Profile("ASYNCHRONOUS") @EnableRabbit @Configuration class TaskAsyncConfiguration extends Object
A InventoryAsyncConfiguration 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 final org.slf4j.Logger
    BOOT_LOGGER
     
    private static final String
    POISON_MESSAGE
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    TaskAsyncConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (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
    taskExchange(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:

  • Constructor Details

    • TaskAsyncConfiguration

      TaskAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

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

    • taskExchange

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

    • 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)