Interface QueryConnector

All Known Implementing Classes:
AbstractQueryConnector, EnumQueryConnector, QueueQueryConnector, ServiceQueryConnector, SQLQueryConnector

public interface QueryConnector
Interface to launch query processes
Author:
pvidal
  • Method Summary

    Modifier and Type
    Method
    Description
    launch(Query query, com.fasterxml.jackson.databind.node.ObjectNode parameters)
    Launch a full query
    subscribe(Query query, ComponentAddress address, com.fasterxml.jackson.databind.node.ObjectNode parameters)
    Subscribe to a queue
  • Method Details

    • launch

      ServiceData launch(Query query, com.fasterxml.jackson.databind.node.ObjectNode parameters) throws AWException
      Launch a full query
      Parameters:
      query - Query to be launched
      parameters - Parameters
      Returns:
      ServiceData with complete output
      Throws:
      AWException - Error launching query
    • subscribe

      ServiceData subscribe(Query query, ComponentAddress address, com.fasterxml.jackson.databind.node.ObjectNode parameters) throws AWException
      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