org.infinispan.commands.write

Class AbstractDataWriteCommand

java.lang.Object

org.infinispan.commands.AbstractLocalFlagAffectedCommand

org.infinispan.commands.AbstractFlagAffectedCommand

org.infinispan.commands.read.AbstractDataCommand

org.infinispan.commands.write.AbstractDataWriteCommand

All Implemented Interfaces:

DataCommand, FlagAffectedCommand, LocalFlagAffectedCommand, MetadataAwareCommand, ReplicableCommand, TopologyAffectedCommand, VisitableCommand, DataWriteCommand, WriteCommand

Direct Known Subclasses:

ApplyDeltaCommand, PutKeyValueCommand, RemoveCommand, ReplaceCommand

public abstract class AbstractDataWriteCommand
extends AbstractDataCommand
implements DataWriteCommand

Stuff common to WriteCommands

Since:

4.0

Author:

Manik Surtani

Field Summary

Fields inherited from class org.infinispan.commands.read.AbstractDataCommand

key

Fields inherited from class org.infinispan.commands.AbstractLocalFlagAffectedCommand

flags

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDataWriteCommand()
protected	AbstractDataWriteCommand(Object key, Set<Flag> flags)

Method Summary

Modifier and Type	Method and Description
boolean	canBlock() If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.
Set<Object>	getAffectedKeys()
boolean	isReturnValueExpected() If true, a return value will be provided when performed remotely.

Methods inherited from class org.infinispan.commands.read.AbstractDataCommand

equals, getKey, getParameters, hashCode, ignoreCommandOnStatus, setKey, setParameters, shouldInvoke, toString

Methods inherited from class org.infinispan.commands.AbstractFlagAffectedCommand

getMetadata, getTopologyId, setMetadata, setTopologyId

Methods inherited from class org.infinispan.commands.AbstractLocalFlagAffectedCommand

getFlags, hasFlag, setFlags, setFlags

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.write.WriteCommand

getValueMatcher, isConditional, isSuccessful, setValueMatcher, updateStatusFromRemoteResponse

Methods inherited from interface org.infinispan.commands.VisitableCommand

acceptVisitor, ignoreCommandOnStatus, shouldInvoke

Methods inherited from interface org.infinispan.commands.TopologyAffectedCommand

getTopologyId, setTopologyId

Methods inherited from interface org.infinispan.commands.ReplicableCommand

getCommandId, getParameters, perform, setParameters

Methods inherited from interface org.infinispan.commands.MetadataAwareCommand

getMetadata, setMetadata

Methods inherited from interface org.infinispan.commands.LocalFlagAffectedCommand

getFlags, hasFlag, setFlags, setFlags

Methods inherited from interface org.infinispan.commands.DataCommand

getKey

Constructor Detail

AbstractDataWriteCommand

protected AbstractDataWriteCommand()

AbstractDataWriteCommand

protected AbstractDataWriteCommand(Object key,
                                   Set<Flag> flags)

Method Detail

getAffectedKeys

public Set<Object> getAffectedKeys()

Specified by:

getAffectedKeys in interface WriteCommand

Returns:

a collection of keys affected by this write command. Some commands - such as ClearCommand - may return an empty collection for this method.

isReturnValueExpected

public boolean isReturnValueExpected()

Description copied from interface: ReplicableCommand

If true, a return value will be provided when performed remotely. Otherwise, a remote ResponseGenerator may choose to simply return null to save on marshalling costs.

Specified by:

isReturnValueExpected in interface ReplicableCommand

Overrides:

isReturnValueExpected in class AbstractDataCommand

Returns:

true or false

canBlock

public boolean canBlock()

Description copied from interface: ReplicableCommand

If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool. Otherwise, the command is processed directly in the JGroups thread.

This feature allows to avoid keep a JGroups thread busy that can originate discard of messages and retransmissions. So, the commands that can block (waiting for some state, acquiring locks, etc.) should return true.

Specified by:

canBlock in interface ReplicableCommand

Overrides:

canBlock in class AbstractDataCommand

Returns:

true if the command can block/wait, false otherwise