public class VersionedCommitCommand extends CommitCommand
CommitCommand
except that version information is also carried by this command, used by
optimistically transactional caches making use of write skew checking when using IsolationLevel.REPEATABLE_READ
.Modifier and Type | Field and Description |
---|---|
static byte |
COMMAND_ID |
Constructor and Description |
---|
VersionedCommitCommand() |
VersionedCommitCommand(String cacheName) |
VersionedCommitCommand(String cacheName,
GlobalTransaction gtx) |
Modifier and Type | Method and Description |
---|---|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
EntryVersionsMap |
getUpdatedVersions() |
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput) . |
void |
setUpdatedVersions(EntryVersionsMap updatedVersions) |
String |
toString() |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput . |
acceptVisitor, invalidRemoteTxReturnValue
canBlock, equals, getCacheName, getGlobalTransaction, getOrigin, getRemoteTransaction, getTopologyId, hashCode, ignoreCommandOnStatus, init, isReturnValueExpected, markTransactionAsRemote, perform, readsExistingValues, setOrigin, setTopologyId, shouldInvoke, visitRemoteTransaction
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alwaysReadsExistingValues
getParameters, setParameters
public static final byte COMMAND_ID
public VersionedCommitCommand()
public VersionedCommitCommand(String cacheName, GlobalTransaction gtx)
public VersionedCommitCommand(String cacheName)
public EntryVersionsMap getUpdatedVersions()
public void setUpdatedVersions(EntryVersionsMap updatedVersions)
public byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
getCommandId
in class CommitCommand
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.writeTo
in interface ReplicableCommand
writeTo
in class AbstractTransactionBoundaryCommand
output
- the stream.IOException
- if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.readFrom
in interface ReplicableCommand
readFrom
in class AbstractTransactionBoundaryCommand
input
- the stream to read.IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.public String toString()
toString
in class CommitCommand
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.