Package org.openwms.tms.app

Class TransportationAsyncConfiguration

java.lang.Object
org.openwms.tms.app.TransportationAsyncConfiguration
@Profile("ASYNCHRONOUS") @Configuration @EnableRabbit class TransportationAsyncConfiguration extends Object
A TransportationAsyncConfiguration.
Author:
Heiko Scherrer

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    TransportationAsyncConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) org.springframework.amqp.core.Binding
    commonCommandsBinding(org.springframework.amqp.core.TopicExchange commonCommandsExchange, org.springframework.amqp.core.Queue commonCommandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    commonCommandsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    commonCommandsQueue(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()
     
    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.Binding
    tmsCommandsBinding(org.springframework.amqp.core.TopicExchange tmsCommandsExchange, org.springframework.amqp.core.Queue tmsCommandsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    tmsCommandsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    tmsCommandsQueue(String queueName, String exchangeName)
     
    (package private) org.springframework.amqp.core.TopicExchange
    tmsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Binding
    tmsRequestsBinding(org.springframework.amqp.core.TopicExchange tmsRequestsExchange, org.springframework.amqp.core.Queue tmsRequestsQueue, String routingKey)
     
    (package private) org.springframework.amqp.core.TopicExchange
    tmsRequestsExchange(String exchangeName)
     
    (package private) org.springframework.amqp.core.Queue
    tmsRequestsQueue(String queueName, 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

  • Constructor Details

    • TransportationAsyncConfiguration

      TransportationAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

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

    • tmsExchange

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

    • dlExchange

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

    • dlq

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

    • dlBinding

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

    • commonCommandsExchange

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

    • commonCommandsQueue

      @Bean org.springframework.amqp.core.Queue commonCommandsQueue(@Value("${owms.commands.common.tu.queue-name}") String queueName, @Value("${owms.transportation.dead-letter.exchange-name}") String exchangeName)

    • commonCommandsBinding

      @Bean org.springframework.amqp.core.Binding commonCommandsBinding(org.springframework.amqp.core.TopicExchange commonCommandsExchange, org.springframework.amqp.core.Queue commonCommandsQueue, @Value("${owms.commands.common.tu.routing-key}") String routingKey)

    • tmsCommandsExchange

      @Bean org.springframework.amqp.core.TopicExchange tmsCommandsExchange(@Value("${owms.commands.tms.to.exchange-name}") String exchangeName)

    • tmsCommandsQueue

      @Bean org.springframework.amqp.core.Queue tmsCommandsQueue(@Value("${owms.commands.tms.to.queue-name}") String queueName, @Value("${owms.transportation.dead-letter.exchange-name}") String exchangeName)

    • tmsCommandsBinding

      @Bean org.springframework.amqp.core.Binding tmsCommandsBinding(org.springframework.amqp.core.TopicExchange tmsCommandsExchange, org.springframework.amqp.core.Queue tmsCommandsQueue, @Value("${owms.commands.tms.to.routing-key}") String routingKey)

    • tmsRequestsExchange

      @Bean org.springframework.amqp.core.TopicExchange tmsRequestsExchange(@Value("${owms.requests.tms.to.exchange-name}") String exchangeName)

    • tmsRequestsQueue

      @Bean org.springframework.amqp.core.Queue tmsRequestsQueue(@Value("${owms.requests.tms.to.queue-name}") String queueName, @Value("${owms.transportation.dead-letter.exchange-name}") String exchangeName)

    • tmsRequestsBinding

      @Bean org.springframework.amqp.core.Binding tmsRequestsBinding(org.springframework.amqp.core.TopicExchange tmsRequestsExchange, org.springframework.amqp.core.Queue tmsRequestsQueue, @Value("${owms.requests.tms.to.routing-key}") String routingKey)