Class 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 Details

    • QueueQueryConnector

      public QueueQueryConnector(QueryUtil queryUtil, BaseConfigProperties baseConfigProperties, AweElements elements, NumericService numericService, EncodeService encodeService, com.fasterxml.jackson.databind.ObjectMapper mapper)
      Autowired constructor
      Parameters:
      queryUtil - QueryUtil
      baseConfigProperties - Base configuration properties
      elements - AWE element
      numericService - Numeric service
      encodeService - Encode service
      mapper - Object mapper
  • Method Details

    • 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