|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.commands.read.DistributedExecuteCommand<V>
public class DistributedExecuteCommand<V>
DistributedExecuteCommand is used to migrate Callable and execute it in remote JVM.
Field Summary | |
---|---|
protected Cache |
cache
|
protected Callable<V> |
callable
|
static int |
COMMAND_ID
|
protected Set<Object> |
keys
|
Constructor Summary | |
---|---|
DistributedExecuteCommand()
|
|
DistributedExecuteCommand(Collection<Object> inputKeys,
Callable<V> callable)
|
Method Summary | |
---|---|
Object |
acceptVisitor(InvocationContext ctx,
Visitor visitor)
Accept a visitor, and return the result of accepting this visitor. |
boolean |
equals(Object o)
|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming. |
Object[] |
getParameters()
Used by marshallers to stream this command across a network |
int |
hashCode()
|
void |
init(Cache cache)
|
Object |
perform(InvocationContext context)
Performs invocation of Callable and returns result |
void |
setParameters(int commandId,
Object[] args)
Used by the CommandsFactory to create a command from raw data read off a stream. |
boolean |
shouldInvoke(InvocationContext ctx)
Used by the InboundInvocationHandler to determine whether the command should be invoked or not. |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int COMMAND_ID
protected Cache cache
protected Set<Object> keys
protected Callable<V> callable
Constructor Detail |
---|
public DistributedExecuteCommand(Collection<Object> inputKeys, Callable<V> callable)
public DistributedExecuteCommand()
Method Detail |
---|
public void init(Cache cache)
public Object acceptVisitor(InvocationContext ctx, Visitor visitor) throws Throwable
VisitableCommand
acceptVisitor
in interface VisitableCommand
ctx
- invocation contextvisitor
- visitor to accept
Throwable
- in the event of problemspublic boolean shouldInvoke(InvocationContext ctx)
VisitableCommand
shouldInvoke
in interface VisitableCommand
public Object perform(InvocationContext context) throws Throwable
perform
in interface ReplicableCommand
ctx
- invocation context
Throwable
- in the event of problems.public byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
public Object[] getParameters()
ReplicableCommand
getParameters
in interface ReplicableCommand
public void setParameters(int commandId, Object[] args)
ReplicableCommand
CommandsFactory
to create a command from raw data read off a stream.
setParameters
in interface ReplicableCommand
commandId
- command id to set. This is usually unused but *could* be used in the event of a command having
multiple IDs, such as PutKeyValueCommand
.args
- object array of argspublic boolean equals(Object o)
equals
in class Object
public int hashCode()
hashCode
in class Object
|
--> | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |