org.infinispan.commands.remote.recovery
Class GetInDoubtTransactionsCommand

java.lang.Object
  org.infinispan.commands.remote.BaseRpcCommand
      org.infinispan.commands.remote.recovery.RecoveryCommand
          org.infinispan.commands.remote.recovery.GetInDoubtTransactionsCommand

All Implemented Interfaces:

CacheRpcCommand, ReplicableCommand

public class GetInDoubtTransactionsCommand
extends RecoveryCommand

Rpc to obtain all in-doubt prepared transactions stored on remote nodes. A transaction is in doubt if it is prepared and the node where it started has crashed.

Since:

5.0

Author:

Mircea.Markus@jboss.com

Field Summary

static int

COMMAND_ID

Fields inherited from class org.infinispan.commands.remote.recovery.RecoveryCommand

recoveryManager

Fields inherited from class org.infinispan.commands.remote.BaseRpcCommand

cacheName

Constructor Summary

GetInDoubtTransactionsCommand(String cacheName)

Method Summary

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
List<Xid>	perform(InvocationContext ctx) Performs the primary function of the command.
void	setParameters(int commandId, Object[] parameters) Used by the CommandsFactory to create a command from raw data read off a stream.
String	toString()

Methods inherited from class org.infinispan.commands.remote.recovery.RecoveryCommand

init, isReturnValueExpected

Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand

getCacheName, getOrigin, setOrigin

Methods inherited from class java.lang.Object

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

Field Detail

COMMAND_ID

public static final int COMMAND_ID

See Also:

Constant Field Values

Constructor Detail

GetInDoubtTransactionsCommand

public GetInDoubtTransactionsCommand(String cacheName)

Method Detail

perform

public List<Xid> 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.

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