Package org.infinispan.commands.remote
Class ClusteredGetAllCommand<K,V>
- java.lang.Object
-
- org.infinispan.commands.remote.BaseRpcCommand
-
- org.infinispan.commands.remote.BaseClusteredReadCommand
-
- org.infinispan.commands.remote.ClusteredGetAllCommand<K,V>
-
- All Implemented Interfaces:
CacheRpcCommand
,ReplicableCommand
,TopologyAffectedCommand
public class ClusteredGetAllCommand<K,V> extends BaseClusteredReadCommand
Issues a remote getAll call. This is not aVisitableCommand
and hence not passed up the interceptor chain.- Author:
- Radim Vansa <rvansa@redhat.com>
-
-
Field Summary
Fields Modifier and Type Field Description static byte
COMMAND_ID
-
Fields inherited from class org.infinispan.commands.remote.BaseClusteredReadCommand
topologyId
-
Fields inherited from class org.infinispan.commands.remote.BaseRpcCommand
cacheName
-
-
Constructor Summary
Constructors Constructor Description ClusteredGetAllCommand(ByteString cacheName)
ClusteredGetAllCommand(ByteString cacheName, List<?> keys, long flags, GlobalTransaction gtx)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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, AsyncInterceptorChain interceptorChain, TransactionTable txTable)
CompletableFuture<Object>
invokeAsync()
Invoke the command asynchronously.boolean
isReturnValueExpected()
If true, a return value will be provided when performed remotely.void
readFrom(ObjectInput input)
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.String
toString()
void
writeTo(ObjectOutput output)
Writes this instance to theObjectOutput
.-
Methods inherited from class org.infinispan.commands.remote.BaseClusteredReadCommand
getFlagsBitSet, getTopologyId, hasAnyFlag, printFlags, setFlagsBitSet, setTopologyId
-
Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand
canBlock, getCacheName, getOrigin, setOrigin
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.infinispan.commands.ReplicableCommand
canBlock, invoke, isSuccessful, perform
-
-
-
-
Field Detail
-
COMMAND_ID
public static final byte COMMAND_ID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ClusteredGetAllCommand
public ClusteredGetAllCommand(ByteString cacheName)
-
ClusteredGetAllCommand
public ClusteredGetAllCommand(ByteString cacheName, List<?> keys, long flags, GlobalTransaction gtx)
-
-
Method Detail
-
init
public void init(InvocationContextFactory icf, CommandsFactory commandsFactory, InternalEntryFactory entryFactory, AsyncInterceptorChain interceptorChain, TransactionTable txTable)
-
invokeAsync
public CompletableFuture<Object> invokeAsync() throws Throwable
Description copied from interface:ReplicableCommand
Invoke the command asynchronously.This method replaces
ReplicableCommand.perform(InvocationContext)
for remote execution. The default implementation andReplicableCommand.perform(InvocationContext)
will be removed in future versions.- Throws:
Throwable
-
getKeys
public List<?> getKeys()
-
getCommandId
public byte getCommandId()
Description copied from interface:ReplicableCommand
Used by marshallers to convert this command into an id for streaming.- Returns:
- the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.
-
writeTo
public void writeTo(ObjectOutput output) throws IOException
Description copied from interface:ReplicableCommand
Writes this instance to theObjectOutput
.- Parameters:
output
- the stream.- Throws:
IOException
- if an error occurred during the I/O.
-
readFrom
public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
Description copied from interface:ReplicableCommand
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.- Parameters:
input
- the stream to read.- Throws:
IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.
-
isReturnValueExpected
public boolean isReturnValueExpected()
Description copied from interface:ReplicableCommand
If true, a return value will be provided when performed remotely. Otherwise, a remoteResponseGenerator
may choose to simply return null to save on marshalling costs.- Returns:
- true or false
-
toString
public String toString()
- Overrides:
toString
in classBaseRpcCommand
-
-