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
Fields Modifier and Type Field Description 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
Constructors Constructor Description GetInDoubtTransactionsCommand(ByteString cacheName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte
getCommandId()
Used by marshallers to convert this command into an id for streaming.List<Xid>
perform(InvocationContext ctx)
Performs the primary function of the command.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.recovery.RecoveryCommand
init, isReturnValueExpected
-
Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand
canBlock, getCacheName, getOrigin, setOrigin
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.infinispan.commands.ReplicableCommand
invoke, invokeAsync, isSuccessful
-
-
-
-
Field Detail
-
COMMAND_ID
public static final int COMMAND_ID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
GetInDoubtTransactionsCommand
public GetInDoubtTransactionsCommand(ByteString 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.
-
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.
-
toString
public String toString()
- Overrides:
toString
in classBaseRpcCommand
-
-