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 Summary

Constructors

Constructor	Description
JmsConfig()

Method Summary

Modifier and Type	Method	Description
AweJmsDestination	aweJmsDestination(AweElements elements, QueryService queryService, EncodeService encodeService)	AWE JMS Destination
org.springframework.jms.config.JmsListenerContainerFactory	jmsListenerContainerFactory(javax.jms.ConnectionFactory connectionFactory, org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer configurer)	Listener container factory
MessageBuilder	messageBuilder(org.springframework.web.context.WebApplicationContext context, XStreamSerializer serializer)	Message builder
QueueBuilder	queueBuilder(AweJmsDestination jmsDestination, javax.jms.ConnectionFactory connectionFactory, org.springframework.transaction.PlatformTransactionManager transactionManager, QueryUtil queryUtil, BaseConfigProperties baseConfigProperties)	Queue builder
QueueListener	queueListener(QueryService queryService, BroadcastService broadcastService)	Queue listener
QueueMaintainConnector	queueMaintainConnector()	Queue Maintain connector
QueueProcessor	queueProcessor(XStreamSerializer serializer)	Queue processor
QueueQueryConnector	queueQueryConnector(QueryUtil queryUtil, BaseConfigProperties baseConfigProperties, AweElements elements, NumericService numericService, EncodeService encodeService)	Queue Query connector

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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