Package com.almis.awe.autoconfigure

Class JmsConfig

java.lang.Object
com.almis.awe.autoconfigure.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 Details

    • JmsConfig

      public JmsConfig()

  • Method Details

    • jmsListenerContainerFactory

      @Bean public org.springframework.jms.config.JmsListenerContainerFactory jmsListenerContainerFactory(jakarta.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, com.fasterxml.jackson.databind.ObjectMapper mapper)
      Queue Query connector
      Parameters:
      queryUtil - Query util
      baseConfigProperties - Base configuration properties
      elements - AWE elements
      numericService - Numeric service
      encodeService - Encode service
      mapper - Object mapper
      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, jakarta.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