org.infinispan.statetransfer
Class StateRequestCommand
java.lang.Object
org.infinispan.commands.remote.BaseRpcCommand
org.infinispan.statetransfer.StateRequestCommand
- All Implemented Interfaces:
- CacheRpcCommand, ReplicableCommand
public class StateRequestCommand
- extends BaseRpcCommand
This command is used by a StateConsumer to request transactions and cache entries from a StateProvider.
- Since:
- 5.2
- Author:
- anistor@redhat.com
COMMAND_ID
public static final byte COMMAND_ID
- See Also:
- Constant Field Values
StateRequestCommand
public StateRequestCommand(String cacheName)
StateRequestCommand
public StateRequestCommand(String cacheName,
StateRequestCommand.Type type,
Address origin,
int topologyId,
Set<Integer> segments)
init
public void init(StateProvider stateProvider)
perform
public Object perform(InvocationContext ctx)
throws Throwable
- Description copied from interface:
ReplicableCommand
- Performs the primary function of the command. Please see specific implementation classes for details on what is
performed as well as return types. Important: this method will be invoked at the end of interceptors chain.
It should never be called directly from a custom interceptor.
- Parameters:
ctx
- invocation context
- Returns:
- arbitrary return value generated by performing this command
- Throws:
Throwable
- in the event of problems.
isReturnValueExpected
public boolean isReturnValueExpected()
- Description copied from interface:
ReplicableCommand
- If true, a return value will be provided when performed remotely. Otherwise, a remote
ResponseGenerator
may choose to simply return null to save on marshalling costs.
- Returns:
- true or false
getType
public StateRequestCommand.Type getType()
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.
getParameters
public Object[] getParameters()
- Description copied from interface:
ReplicableCommand
- Used by marshallers to stream this command across a network
- Returns:
- an object array of arguments, compatible with pre-2.2.0 MethodCall args.
setParameters
public void setParameters(int commandId,
Object[] parameters)
- Description copied from interface:
ReplicableCommand
- Used by the
CommandsFactory
to create a command from raw data read off a stream.
- Parameters:
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
.parameters
- object array of args
toString
public String toString()
- Overrides:
toString
in class BaseRpcCommand
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.