org.infinispan.query.clustered
Class ClusteredQueryInvoker

java.lang.Object
  org.infinispan.query.clustered.ClusteredQueryInvoker

public class ClusteredQueryInvoker
extends Object

Invoke a CusteredQueryCommand on the cluster, including on own node.

Since:

5.1

Author:

Israel Lacerra , Sanne Grinovero (C) 2011 Red Hat Inc.

Method Summary

List<QueryResponse>	broadcast(ClusteredQueryCommand clusteredQuery) Broadcast this ClusteredQueryCommand to all cluster nodes.
Object	getValue(int doc, Address address, UUID queryId) Retrieves the value (using doc index) in a remote query instance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getValue

public Object getValue(int doc,
                       Address address,
                       UUID queryId)

Retrieves the value (using doc index) in a remote query instance

Parameters:

doc - Doc index of the value on remote query

address - Address of the node who has the value

queryId - Id of the query

Returns:

The value of index doc of the query with queryId on node at address

broadcast

public List<QueryResponse> broadcast(ClusteredQueryCommand clusteredQuery)

Broadcast this ClusteredQueryCommand to all cluster nodes. The command will be also invoked on local node.

Parameters:

clusteredQuery -

Returns:

A list with all responses