Class PreferencesAsyncConfiguration

java.lang.Object
org.openwms.core.preferences.app.PreferencesAsyncConfiguration
@Profile("AMQP") @RefreshScope @EnableRabbit @Configuration public class PreferencesAsyncConfiguration extends Object
A PreferencesAsyncConfiguration contains the microservice' asynchronous configuration that is activated on Spring Profile SpringProfiles.AMQP.
Author:
Heiko Scherrer

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    PreferencesAsyncConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptor
    interceptor()
     
    (package private) org.springframework.amqp.core.TopicExchange
    lgExchange(String exchangeName)
     
    (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 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

    • PreferencesAsyncConfiguration

      public PreferencesAsyncConfiguration()

  • Method Details

    • messageConverter

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

    • serializerMessageConverter

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

    • interceptor

      @Bean org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptor interceptor()

    • rabbitTemplate

      @RefreshScope @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)

    • lgExchange

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