Package com.rpl.rama

Interface QueryTopologyClient<T>

Type Parameters:
T - Type of returned value
public interface QueryTopologyClient<T>
Client for invoking a query topology. A QueryTopologyClient is retrieved using a RamaClusterManager on a real cluster or InProcessCluster in a test environment.
See Also:

  • Method Details

    • invoke

      T invoke(Object... args)
      Blocking invoke. Number of arguments provided must match number of arguments declared on query topology.
      Parameters:
      args - Arguments
      Returns:
      Result of query topology

    • invokeAsync

      CompletableFuture<T> invokeAsync(Object... args)
      Non-blocking invoke. Number of arguments provided must match number of arguments declared on query topology.
      Parameters:
      args - Arguments
      Returns:
      Future for result of query topology