Package com.almis.awe.service.data.connector.query

Class QueueQueryConnector

java.lang.Object

com.almis.awe.config.ServiceConfig

com.almis.awe.service.data.connector.query.AbstractQueryConnector

com.almis.awe.service.data.connector.query.QueueQueryConnector

All Implemented Interfaces:

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

public class QueueQueryConnector
extends AbstractQueryConnector

QueueQueryConnector Class Connection class between QueryLauncher and EnumBuilder

Author:

Pablo GARCIA 25-07-2017

Constructor Summary

Constructors

Constructor	Description
QueueQueryConnector(QueryUtil queryUtil, BaseConfigProperties baseConfigProperties, AweElements elements, NumericService numericService, EncodeService encodeService)	Autowired constructor

Method Summary

Modifier and Type	Method	Description
ServiceData	launch(Query query, com.fasterxml.jackson.databind.node.ObjectNode parameters)	Launch a full query
ServiceData	onSubscriptionData(Query query, ServiceData subscriptionData, Map<String,QueryParameter> parameterMap)	Manage subscription data
ServiceData	subscribe(Query query, ComponentAddress address, com.fasterxml.jackson.databind.node.ObjectNode parameters)	Subscribe to a queue

Methods inherited from class com.almis.awe.service.data.connector.query.AbstractQueryConnector

buildResults, fillDataList, generateResults, getQueryUtil, processDataList, sortDataList

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

QueueQueryConnector

public QueueQueryConnector(QueryUtil queryUtil,
                           BaseConfigProperties baseConfigProperties,
                           AweElements elements,
                           NumericService numericService,
                           EncodeService encodeService)

Autowired constructor

Parameters:

queryUtil - QueryUtil

baseConfigProperties - Base configuration properties

elements - AWE element

numericService - Numeric service

encodeService - Encode service

Method Detail

launch

public ServiceData launch(Query query,
                          com.fasterxml.jackson.databind.node.ObjectNode parameters)
                   throws AWException

Description copied from interface: QueryConnector

Launch a full query

Parameters:

query - Query to be launched

parameters - Parameters

Returns:

ServiceData with complete output

Throws:

AWException - Error launching query

subscribe

public ServiceData subscribe(Query query,
                             ComponentAddress address,
                             com.fasterxml.jackson.databind.node.ObjectNode parameters)
                      throws AWException

Description copied from interface: QueryConnector

Subscribe to a queue

Parameters:

query - Query to be subscribed to

address - Address of the subscribed component

parameters - Parameters

Returns:

Service data with execution info

Throws:

AWException - Error on subscription

onSubscriptionData

public ServiceData onSubscriptionData(Query query,
                                      ServiceData subscriptionData,
                                      Map<String,QueryParameter> parameterMap)
                               throws AWException

Manage subscription data

Parameters:

query - Query

subscriptionData - Subscription data

parameterMap - Parameter map

Returns:

Service data with client actions

Throws:

AWException - Error managing subscription data