Class AbstractWriteKeyCommand<K,V>

java.lang.Object

org.infinispan.commands.read.AbstractDataCommand

org.infinispan.commands.write.AbstractDataWriteCommand

org.infinispan.commands.functional.AbstractWriteKeyCommand<K,V>

All Implemented Interfaces:

DataCommand, FlagAffectedCommand, FunctionalCommand<K,V>, CacheRpcCommand, ReplicableCommand, SegmentSpecificCommand, TopologyAffectedCommand, TracedCommand, VisitableCommand, DataWriteCommand, WriteCommand, VersionAware, RemoteLockCommand

Direct Known Subclasses:

ReadWriteKeyCommand, ReadWriteKeyValueCommand, WriteOnlyKeyCommand, WriteOnlyKeyValueCommand

public abstract class AbstractWriteKeyCommand<K,V>
extends AbstractDataWriteCommand
implements FunctionalCommand<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface VisitableCommand

VisitableCommand.LoadType

Field Summary

Fields inherited from class AbstractDataWriteCommand

commandInvocationId

Fields inherited from class AbstractDataCommand

cacheName, key, origin, segment, spanAttributes, topologyId

Fields inherited from interface VisitableCommand

log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractWriteKeyCommand(ByteString cacheName, Object key, ValueMatcher valueMatcher, int segment, CommandInvocationId id, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
protected	AbstractWriteKeyCommand(ByteString cacheName, MarshallableObject<?> wrappedKey, long flags, int topologyId, int segment, CommandInvocationId commandInvocationId, Params params, ValueMatcher valueMatcher, DataConversion keyDataConversion, DataConversion valueDataConversion, PrivateMetadata internalMetadata)

Method Summary

Modifier and Type	Method	Description
void	fail()	Make subsequent invocations of WriteCommand.isSuccessful() return false.
PrivateMetadata	getInternalMetadata()
DataConversion	getKeyDataConversion()
Params	getParams()
DataConversion	getValueDataConversion()
ValueMatcher	getValueMatcher()
void	init(ComponentRegistry componentRegistry)
boolean	isSuccessful()	If true, a return value will be marshalled as a SuccessfulResponse, otherwise it will be marshalled as a UnsuccessfulResponse.
void	setInternalMetadata(PrivateMetadata internalMetadata)
void	setValueMatcher(ValueMatcher valueMatcher)
String	toString()

Methods inherited from class AbstractDataWriteCommand

getAffectedKeys, getCommandInvocationId, getKeyLockOwner, getKeysToLock, hasSkipLocking, hasZeroLockAcquisition, isReturnValueExpected

Methods inherited from class AbstractDataCommand

equals, getCacheName, getFlagsBitSet, getFlagsWithoutRemote, getKey, getOrigin, getSegment, getSpanAttributes, getTopologyId, getWrappedKey, hashCode, printFlags, setFlagsBitSet, setKey, setOrigin, setSpanAttributes, setTopologyId

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface CacheRpcCommand

getCacheName, getOrigin, setOrigin

Methods inherited from interface DataCommand

getKey

Methods inherited from interface DataWriteCommand

getInternalMetadata, setInternalMetadata

Methods inherited from interface FlagAffectedCommand

addFlags, getFlags, getFlagsBitSet, hasAllFlags, hasAnyFlag, setFlagsBitSet

Methods inherited from interface FunctionalCommand

toMutation

Methods inherited from interface ReplicableCommand

getCommandId, logThrowable, readFrom, supportedSince, writeTo

Methods inherited from interface SegmentSpecificCommand

getSegment

Methods inherited from interface TopologyAffectedCommand

getTopologyId, setTopologyId

Methods inherited from interface TracedCommand

getOperationName, getSpanAttributes, setSpanAttributes

Methods inherited from interface VisitableCommand

acceptVisitor, invokeAsync, loadType

Methods inherited from interface WriteCommand

isConditional, isWriteOnly, shouldReplicate

Constructor Details

AbstractWriteKeyCommand

protected AbstractWriteKeyCommand(ByteString cacheName,
 MarshallableObject<?> wrappedKey,
 long flags,
 int topologyId,
 int segment,
 CommandInvocationId commandInvocationId,
 Params params,
 ValueMatcher valueMatcher,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion,
 PrivateMetadata internalMetadata)

AbstractWriteKeyCommand

protected AbstractWriteKeyCommand(ByteString cacheName,
 Object key,
 ValueMatcher valueMatcher,
 int segment,
 CommandInvocationId id,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Method Details

init

public void init(ComponentRegistry componentRegistry)

Specified by:

init in interface VisitableCommand

getParams

@ProtoField(7)
public Params getParams()

Specified by:

getParams in interface FunctionalCommand<K,V>

getValueMatcher

@ProtoField(8)
public ValueMatcher getValueMatcher()

Specified by:

getValueMatcher in interface WriteCommand

Returns:

The current value matching policy.

getKeyDataConversion

@ProtoField(9)
public DataConversion getKeyDataConversion()

Specified by:

getKeyDataConversion in interface FunctionalCommand<K,V>

getValueDataConversion

@ProtoField(10)
public DataConversion getValueDataConversion()

Specified by:

getValueDataConversion in interface FunctionalCommand<K,V>

getInternalMetadata

@ProtoField(11)
public PrivateMetadata getInternalMetadata()

Specified by:

getInternalMetadata in interface DataWriteCommand

setInternalMetadata

public void setInternalMetadata(PrivateMetadata internalMetadata)

Specified by:

setInternalMetadata in interface DataWriteCommand

setValueMatcher

public void setValueMatcher(ValueMatcher valueMatcher)

Specified by:

setValueMatcher in interface WriteCommand

Parameters:

valueMatcher - The new value matching policy.

isSuccessful

public boolean isSuccessful()

Description copied from interface: ReplicableCommand

If true, a return value will be marshalled as a SuccessfulResponse, otherwise it will be marshalled as a UnsuccessfulResponse.

Specified by:

isSuccessful in interface ReplicableCommand

Specified by:

isSuccessful in interface WriteCommand

Returns:

true if the command completed successfully, false otherwise.

fail

public void fail()

Description copied from interface: WriteCommand

Make subsequent invocations of WriteCommand.isSuccessful() return false.

Specified by:

fail in interface WriteCommand

toString

public String toString()

Overrides:

toString in class AbstractDataCommand