public class ClusteredGetAllCommand<K,V> extends LocalFlagAffectedRpcCommand
VisitableCommand
and hence not passed up the
CommandInterceptor
chain.Modifier and Type | Field and Description |
---|---|
static byte |
COMMAND_ID |
flags
cacheName
Constructor and Description |
---|
ClusteredGetAllCommand(String cacheName) |
ClusteredGetAllCommand(String cacheName,
List<?> keys,
Set<Flag> flags,
GlobalTransaction gtx,
Equivalence<? super K> keyEquivalence) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
List<?> |
getKeys() |
int |
hashCode() |
void |
init(InvocationContextFactory icf,
CommandsFactory commandsFactory,
InternalEntryFactory entryFactory,
InterceptorChain interceptorChain,
TransactionTable txTable,
Equivalence<? super K> keyEquivalence) |
boolean |
isReturnValueExpected()
If true, a return value will be provided when performed remotely.
|
Object |
perform(InvocationContext ctx)
Performs the primary function of the command.
|
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput) . |
String |
toString() |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput . |
getFlags, hasFlag, setFlags
canBlock, getCacheName, getOrigin, setOrigin
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
addFlag, addFlags, setFlags
getParameters, setParameters
public static final byte COMMAND_ID
public ClusteredGetAllCommand(String cacheName)
public ClusteredGetAllCommand(String cacheName, List<?> keys, Set<Flag> flags, GlobalTransaction gtx, Equivalence<? super K> keyEquivalence)
public void init(InvocationContextFactory icf, CommandsFactory commandsFactory, InternalEntryFactory entryFactory, InterceptorChain interceptorChain, TransactionTable txTable, Equivalence<? super K> keyEquivalence)
public Object perform(InvocationContext ctx) throws Throwable
ReplicableCommand
ctx
- invocation contextThrowable
- in the event of problems.public List<?> getKeys()
public byte getCommandId()
ReplicableCommand
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.output
- the stream.IOException
- if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.input
- the stream to read.IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.public boolean isReturnValueExpected()
ReplicableCommand
ResponseGenerator
may choose to simply return null to save on marshalling costs.public String toString()
toString
in class BaseRpcCommand
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.