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 |
commandInvocationId
key, 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, hasZeroLockAcquisition
getFlagsBitSet, getKey, getSegment, getTopologyId, printFlags, setFlagsBitSet, setKey, setTopologyId
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getInternalMetadata, setInternalMetadata
isWriteOnly, updateStatusFromRemoteResponse
getKey
getTopologyId, setTopologyId
addFlag, addFlags, addFlags, getFlags, getFlagsBitSet, hasAllFlags, hasAnyFlag, hasFlag, setFlags, setFlagsBitSet
extractSegment, getSegment
public 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
VisitableCommand
acceptVisitor
in interface VisitableCommand
ctx
- invocation contextvisitor
- visitor to acceptThrowable
- in the event of problemspublic byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
public void setMetadata(Metadata metadata)
MetadataAwareCommand
setMetadata
in interface MetadataAwareCommand
public Metadata getMetadata()
MetadataAwareCommand
getMetadata
in interface MetadataAwareCommand
public boolean equals(Object o)
equals
in class AbstractDataCommand
public int hashCode()
hashCode
in class AbstractDataCommand
public String toString()
toString
in class AbstractDataCommand
public boolean isSuccessful()
ReplicableCommand
SuccessfulResponse
,
otherwise it will be marshalled as a UnsuccessfulResponse
.isSuccessful
in interface ReplicableCommand
isSuccessful
in interface WriteCommand
public boolean isConditional()
WriteCommand
ConcurrentMap.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 WriteCommand
public void nonExistant()
public boolean isNonExistent()
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.writeTo
in interface ReplicableCommand
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
input
- 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 WriteCommand
public void setValueMatcher(ValueMatcher valueMatcher)
setValueMatcher
in interface WriteCommand
valueMatcher
- The new value matching policy.public void fail()
WriteCommand
WriteCommand.isSuccessful()
return false
.fail
in interface WriteCommand
public VisitableCommand.LoadType loadType()
loadType
in interface VisitableCommand
public Object getValue()
public void setValue(Object value)
public final boolean isReturnValueExpected()
ReplicableCommand
ResponseGenerator
may choose to simply return null to save on marshalling
costs.isReturnValueExpected
in interface ReplicableCommand
isReturnValueExpected
in class AbstractDataWriteCommand
public PrivateMetadata getInternalMetadata()
getInternalMetadata
in interface DataWriteCommand
public void setInternalMetadata(PrivateMetadata internalMetadata)
setInternalMetadata
in interface DataWriteCommand
Copyright © 2021 JBoss by Red Hat. All rights reserved.