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:

Query topology documentation

Method Summary

Modifier and Type	Method and Description
T	invoke(java.lang.Object... args) Blocking invoke.
java.util.concurrent.CompletableFuture<T>	invokeAsync(java.lang.Object... args) Non-blocking invoke.

Method Detail

invoke

T invoke(java.lang.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

java.util.concurrent.CompletableFuture<T> invokeAsync(java.lang.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