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