public class RemoveCommand extends AbstractDataWriteCommand implements MetadataAwareCommand
| Modifier and Type | Field and Description |
|---|---|
static byte |
COMMAND_ID |
protected Metadata |
metadata |
protected boolean |
successful |
protected Object |
value
When not null, value indicates that the entry should only be removed if the key is mapped to this value.
|
protected ValueMatcher |
valueMatcher |
commandInvocationIdkey, segment| Constructor and Description |
|---|
RemoveCommand() |
RemoveCommand(Object key,
Object value,
int segment,
long flagsBitSet,
CommandInvocationId commandInvocationId) |
| Modifier and Type | Method and Description |
|---|---|
Object |
acceptVisitor(InvocationContext ctx,
Visitor visitor)
Accept a visitor, and return the result of accepting this visitor.
|
boolean |
equals(Object o) |
void |
fail()
Make subsequent invocations of
WriteCommand.isSuccessful() return false. |
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
PrivateMetadata |
getInternalMetadata() |
Metadata |
getMetadata()
Get metadata of this command.
|
Object |
getValue() |
ValueMatcher |
getValueMatcher() |
int |
hashCode() |
boolean |
isConditional()
Certain commands only work based on a certain condition or state of the cache.
|
boolean |
isNonExistent() |
boolean |
isReturnValueExpected()
If true, a return value will be provided when performed remotely.
|
boolean |
isSuccessful()
If true, a return value will be marshalled as a
SuccessfulResponse,
otherwise it will be marshalled as a UnsuccessfulResponse. |
VisitableCommand.LoadType |
loadType() |
void |
nonExistant() |
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput). |
void |
setInternalMetadata(PrivateMetadata internalMetadata) |
void |
setMetadata(Metadata metadata)
Sets metadata for this command.
|
void |
setValue(Object value) |
void |
setValueMatcher(ValueMatcher valueMatcher) |
String |
toString() |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput. |
getAffectedKeys, getCommandInvocationId, getKeyLockOwner, getKeysToLock, hasSkipLocking, hasZeroLockAcquisitiongetFlagsBitSet, getKey, getSegment, getTopologyId, printFlags, setFlagsBitSet, setKey, setTopologyIdclone, finalize, getClass, notify, notifyAll, wait, wait, waitgetInternalMetadata, setInternalMetadataisWriteOnly, updateStatusFromRemoteResponsegetKeygetTopologyId, setTopologyIdaddFlag, addFlags, addFlags, getFlags, getFlagsBitSet, hasAllFlags, hasAnyFlag, hasFlag, setFlags, setFlagsBitSetextractSegment, getSegmentpublic static final byte COMMAND_ID
protected boolean successful
protected Metadata metadata
protected ValueMatcher valueMatcher
protected Object value
public RemoveCommand(Object key, Object value, int segment, long flagsBitSet, CommandInvocationId commandInvocationId)
public RemoveCommand()
public Object acceptVisitor(InvocationContext ctx, Visitor visitor) throws Throwable
VisitableCommandacceptVisitor in interface VisitableCommandctx - invocation contextvisitor - visitor to acceptThrowable - in the event of problemspublic byte getCommandId()
ReplicableCommandgetCommandId in interface ReplicableCommandpublic void setMetadata(Metadata metadata)
MetadataAwareCommandsetMetadata in interface MetadataAwareCommandpublic Metadata getMetadata()
MetadataAwareCommandgetMetadata in interface MetadataAwareCommandpublic boolean equals(Object o)
equals in class AbstractDataCommandpublic int hashCode()
hashCode in class AbstractDataCommandpublic String toString()
toString in class AbstractDataCommandpublic boolean isSuccessful()
ReplicableCommandSuccessfulResponse,
otherwise it will be marshalled as a UnsuccessfulResponse.isSuccessful in interface ReplicableCommandisSuccessful in interface WriteCommandpublic boolean isConditional()
WriteCommandConcurrentMap.putIfAbsent(Object, Object) only does anything if a condition is met, i.e., the entry in
question is not already present. This method tests whether the command in question is conditional or not.isConditional in interface WriteCommandpublic void nonExistant()
public boolean isNonExistent()
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommandObjectOutput.writeTo in interface ReplicableCommandoutput - the stream.IOException - if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommandReplicableCommand.writeTo(ObjectOutput).readFrom in interface ReplicableCommandinput - the stream to read.IOException - if an error occurred during the I/O.ClassNotFoundException - if it tries to load an undefined class.public ValueMatcher getValueMatcher()
getValueMatcher in interface WriteCommandpublic void setValueMatcher(ValueMatcher valueMatcher)
setValueMatcher in interface WriteCommandvalueMatcher - The new value matching policy.public void fail()
WriteCommandWriteCommand.isSuccessful() return false.fail in interface WriteCommandpublic VisitableCommand.LoadType loadType()
loadType in interface VisitableCommandpublic Object getValue()
public void setValue(Object value)
public final boolean isReturnValueExpected()
ReplicableCommandResponseGenerator may choose to simply return null to save on marshalling
costs.isReturnValueExpected in interface ReplicableCommandisReturnValueExpected in class AbstractDataWriteCommandpublic PrivateMetadata getInternalMetadata()
getInternalMetadata in interface DataWriteCommandpublic void setInternalMetadata(PrivateMetadata internalMetadata)
setInternalMetadata in interface DataWriteCommandCopyright © 2022 JBoss by Red Hat. All rights reserved.