Class JmsConfig


  • @Configuration
    @ConditionalOnProperty(name="awe.application.jms.enabled",
                           havingValue="true")
    @EnableJms
    @Lazy
    public class JmsConfig
    extends Object
    Class used to launch initial load treads
    • Constructor Detail

      • JmsConfig

        public JmsConfig()
    • Method Detail

      • jmsListenerContainerFactory

        @Bean
        public org.springframework.jms.config.JmsListenerContainerFactory jmsListenerContainerFactory​(javax.jms.ConnectionFactory connectionFactory,
                                                                                                      org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer configurer)
        Listener container factory
        Parameters:
        connectionFactory - Connection factory
        configurer - Configurer
        Returns:
        Container factory
      • aweJmsDestination

        @Bean
        @ConditionalOnMissingBean
        public AweJmsDestination aweJmsDestination​(AweElements elements,
                                                   QueryService queryService,
                                                   EncodeService encodeService)
        AWE JMS Destination
        Parameters:
        elements - Awe Elements
        queryService - Query service
        encodeService - Encode service
        Returns:
        JMS Destination
      • queueQueryConnector

        @Bean
        @ConditionalOnMissingBean
        public QueueQueryConnector queueQueryConnector​(QueryUtil queryUtil,
                                                       BaseConfigProperties baseConfigProperties,
                                                       AweElements elements,
                                                       NumericService numericService,
                                                       EncodeService encodeService)
        Queue Query connector
        Parameters:
        queryUtil - Query util
        baseConfigProperties - Base configuration properties
        elements - AWE elements
        numericService - Numeric service
        encodeService - Encode service
        Returns:
        Queue Query connector bean
      • queueMaintainConnector

        @Bean
        @ConditionalOnMissingBean
        public QueueMaintainConnector queueMaintainConnector()
        Queue Maintain connector
        Returns:
        Queue Query connector bean
      • queueProcessor

        @Bean
        @ConditionalOnMissingBean
        @Scope("prototype")
        public QueueProcessor queueProcessor​(XStreamSerializer serializer)
        Queue processor
        Returns:
        Queue list builder bean
      • queueBuilder

        @Bean
        @ConditionalOnMissingBean
        @Scope("prototype")
        public QueueBuilder queueBuilder​(AweJmsDestination jmsDestination,
                                         javax.jms.ConnectionFactory connectionFactory,
                                         org.springframework.transaction.PlatformTransactionManager transactionManager,
                                         QueryUtil queryUtil,
                                         BaseConfigProperties baseConfigProperties)
        Queue builder
        Parameters:
        jmsDestination - Destination
        connectionFactory - Connection factory
        transactionManager - Transaction manager
        queryUtil - Query utilities
        baseConfigProperties - Base configuration properties
        Returns:
        Queue builder bean
      • messageBuilder

        @Bean
        @ConditionalOnMissingBean
        @Scope("prototype")
        public MessageBuilder messageBuilder​(org.springframework.web.context.WebApplicationContext context,
                                             XStreamSerializer serializer)
        Message builder
        Parameters:
        context - Context
        serializer - Serializer
        Returns:
        Message builder bean
      • queueListener

        @Bean
        @ConditionalOnMissingBean
        @Scope("prototype")
        public QueueListener queueListener​(QueryService queryService,
                                           BroadcastService broadcastService)
        Queue listener
        Parameters:
        queryService - Query service
        broadcastService - Broadcasting service
        Returns:
        Queue listener bean