Package com.almis.awe.service.data.builder

Class QueueBuilder

java.lang.Object

com.almis.awe.config.ServiceConfig

com.almis.awe.service.data.builder.AbstractQueryBuilder

com.almis.awe.service.data.builder.QueueBuilder

All Implemented Interfaces:

QueryBuilder, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class QueueBuilder
extends AbstractQueryBuilder

Generate service datalist

Field Summary

Fields inherited from class com.almis.awe.service.data.builder.AbstractQueryBuilder

componentSortList, parameters, queryUtil, variableIndex, variables

Constructor Summary

Constructors

Constructor	Description
QueueBuilder(AweJmsDestination jmsDestination, javax.jms.ConnectionFactory connectionFactory, org.springframework.transaction.PlatformTransactionManager transactionManager, QueryUtil queryUtil, BaseConfigProperties baseConfigProperties)	Autowired constructor

Method Summary

Modifier and Type	Method	Description
ServiceData	build()	Call the service and returns the ServiceData
ServiceData	receiveMessage(String correlationId)	Receive message from a queue
String	sendMessage(Map<String,Object> parameterList)	Send a message to a queue
String	sendMessage(org.springframework.jms.core.JmsTemplate template, RequestMessage request, Map<String,Object> parameterList)	Send JMS Message
QueueBuilder	setAddress(ComponentAddress address)
QueueBuilder	setParameters(com.fasterxml.jackson.databind.node.ObjectNode parameters)
QueueBuilder	setQuery(Query query)	Set query
QueueBuilder	setQueue(Queue queue)	Set the queue
QueueBuilder	setVariables(Map<String,QueryParameter> parameterMap)	Set variables
ServiceData	subscribe()	Subscribe to a topic queue

Methods inherited from class com.almis.awe.service.data.builder.AbstractQueryBuilder

addComponentSort, extractValuesFromParameters, getVariableAsString, getVariables, transformFromJsonNode

Methods inherited from class com.almis.awe.config.ServiceConfig

containsBean, getApplicationContext, getBean, getBean, getElements, getLocale, getLocale, getProperty, getProperty, getRequest, getSession, setApplicationContext

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueBuilder

public QueueBuilder(AweJmsDestination jmsDestination,
                    javax.jms.ConnectionFactory connectionFactory,
                    org.springframework.transaction.PlatformTransactionManager transactionManager,
                    QueryUtil queryUtil,
                    BaseConfigProperties baseConfigProperties)

Autowired constructor

Parameters:

jmsDestination - JMS Destination

connectionFactory - Connection factory

transactionManager - Transaction manager

queryUtil - Query utilities

baseConfigProperties - Base configuration properties

Method Detail

setQuery

public QueueBuilder setQuery(Query query)

Description copied from interface: QueryBuilder

Set query

Parameters:

query - Query

Returns:

query builder

setQueue

public QueueBuilder setQueue(Queue queue)

Set the queue

Parameters:

queue - Queue

Returns:

this

setAddress

public QueueBuilder setAddress(ComponentAddress address)

setVariables

public QueueBuilder setVariables(Map<String,QueryParameter> parameterMap)

Description copied from class: AbstractQueryBuilder

Set variables

Specified by:

setVariables in interface QueryBuilder

Overrides:

setVariables in class AbstractQueryBuilder

Parameters:

parameterMap - Parameter map

Returns:

this

setParameters

public QueueBuilder setParameters(com.fasterxml.jackson.databind.node.ObjectNode parameters)

build

public ServiceData build()
                  throws AWException

Call the service and returns the ServiceData

Returns:

serviceData

Throws:

AWException - Error calling service

subscribe

public ServiceData subscribe()
                      throws AWException

Subscribe to a topic queue

Returns:

Service data

Throws:

AWException - Error in subscription

sendMessage

public String sendMessage(Map<String,Object> parameterList)
                   throws AWException

Send a message to a queue

Parameters:

parameterList - parameters

Returns:

Correlation ID

Throws:

AWException - Error sending message

receiveMessage

public ServiceData receiveMessage(String correlationId)
                           throws AWException

Receive message from a queue

Parameters:

correlationId - Correlation ID

Returns:

Service data

Throws:

AWException - Error receiving message

sendMessage

public String sendMessage(org.springframework.jms.core.JmsTemplate template,
                          RequestMessage request,
                          Map<String,Object> parameterList)
                   throws AWException

Send JMS Message

Parameters:

template - JMS Template

request - Request

parameterList - Parameter list

Returns:

Correlation ID

Throws:

AWException - Error sending message