Class TxReadOnlyKeyCommand<K,V,R>
- java.lang.Object
-
- org.infinispan.commands.read.AbstractDataCommand
-
- org.infinispan.commands.functional.ReadOnlyKeyCommand<K,V,R>
-
- org.infinispan.commands.functional.TxReadOnlyKeyCommand<K,V,R>
-
- All Implemented Interfaces:
DataCommand
,FlagAffectedCommand
,ReplicableCommand
,SegmentSpecificCommand
,TopologyAffectedCommand
,VisitableCommand
public class TxReadOnlyKeyCommand<K,V,R> extends ReadOnlyKeyCommand<K,V,R>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.commands.VisitableCommand
VisitableCommand.LoadType
-
-
Field Summary
Fields Modifier and Type Field Description static byte
COMMAND_ID
-
Fields inherited from class org.infinispan.commands.functional.ReadOnlyKeyCommand
f, keyDataConversion, params, valueDataConversion
-
Fields inherited from class org.infinispan.commands.read.AbstractDataCommand
key, segment
-
-
Constructor Summary
Constructors Constructor Description TxReadOnlyKeyCommand()
TxReadOnlyKeyCommand(Object key, List<Mutation<K,V,?>> mutations, int segment, org.infinispan.functional.impl.Params params, DataConversion keyDataConversion, DataConversion valueDataConversion, ComponentRegistry componentRegistry)
TxReadOnlyKeyCommand(ReadOnlyKeyCommand other, List<Mutation<K,V,?>> mutations, int segment, org.infinispan.functional.impl.Params params, DataConversion keyDataConversion, DataConversion valueDataConversion, ComponentRegistry componentRegistry)
-
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.void
init(ComponentRegistry componentRegistry)
Object
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.functional.ReadOnlyKeyCommand
acceptVisitor, getKeyDataConversion, getParams, getValueDataConversion, loadType, performOnLostData
-
Methods inherited from class org.infinispan.commands.read.AbstractDataCommand
canBlock, equals, getFlagsBitSet, getKey, getSegment, getTopologyId, hashCode, isReturnValueExpected, printFlags, setFlagsBitSet, setKey, setTopologyId
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.infinispan.commands.FlagAffectedCommand
addFlag, addFlags, addFlags, getFlags, hasAllFlags, hasAnyFlag, hasFlag, setFlags
-
Methods inherited from interface org.infinispan.commands.ReplicableCommand
invoke, invokeAsync, isSuccessful, setOrigin
-
Methods inherited from interface org.infinispan.commands.VisitableCommand
ignoreCommandOnStatus, shouldInvoke
-
-
-
-
Field Detail
-
COMMAND_ID
public static final byte COMMAND_ID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
TxReadOnlyKeyCommand
public TxReadOnlyKeyCommand()
-
TxReadOnlyKeyCommand
public TxReadOnlyKeyCommand(Object key, List<Mutation<K,V,?>> mutations, int segment, org.infinispan.functional.impl.Params params, DataConversion keyDataConversion, DataConversion valueDataConversion, ComponentRegistry componentRegistry)
-
TxReadOnlyKeyCommand
public TxReadOnlyKeyCommand(ReadOnlyKeyCommand other, List<Mutation<K,V,?>> mutations, int segment, org.infinispan.functional.impl.Params params, DataConversion keyDataConversion, DataConversion valueDataConversion, ComponentRegistry componentRegistry)
-
-
Method Detail
-
getCommandId
public byte getCommandId()
Description copied from interface:ReplicableCommand
Used by marshallers to convert this command into an id for streaming.- Specified by:
getCommandId
in interfaceReplicableCommand
- Overrides:
getCommandId
in classReadOnlyKeyCommand<K,V,R>
- 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
.- Specified by:
writeTo
in interfaceReplicableCommand
- Overrides:
writeTo
in classReadOnlyKeyCommand<K,V,R>
- 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)
.- Specified by:
readFrom
in interfaceReplicableCommand
- Overrides:
readFrom
in classReadOnlyKeyCommand<K,V,R>
- 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.
-
init
public void init(ComponentRegistry componentRegistry)
- Overrides:
init
in classReadOnlyKeyCommand<K,V,R>
-
perform
public Object perform(InvocationContext ctx) throws Throwable
Description copied from interface:VisitableCommand
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.- Specified by:
perform
in interfaceReplicableCommand
- Specified by:
perform
in interfaceVisitableCommand
- Overrides:
perform
in classReadOnlyKeyCommand<K,V,R>
- Parameters:
ctx
- invocation context- Returns:
- arbitrary return value generated by performing this command
- Throws:
Throwable
- in the event of problems.
-
-