org.infinispan.commands.functional

Class AbstractWriteManyCommand<K,V>

java.lang.Object

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

All Implemented Interfaces:

FlagAffectedCommand, ParamsCommand, LocalFlagAffectedCommand, MetadataAwareCommand, ReplicableCommand, TopologyAffectedCommand, VisitableCommand, WriteCommand

Direct Known Subclasses:

ReadWriteManyCommand, ReadWriteManyEntriesCommand, WriteOnlyManyCommand, WriteOnlyManyEntriesCommand

public abstract class AbstractWriteManyCommand<K,V>
extends Object
implements WriteCommand, ParamsCommand

Constructor Summary

Constructors

Constructor and Description
AbstractWriteManyCommand()

Method Summary

Modifier and Type	Method and Description
Set<Flag>	getFlags()
Metadata	getMetadata() Get metadata of this command.
Params	getParams()
int	getTopologyId()
ValueMatcher	getValueMatcher()
boolean	hasFlag(Flag flag) Check whether a particular flag is present in the command
boolean	isConditional() Certain commands only work based on a certain condition or state of the cache.
boolean	isForwarded()
boolean	isSuccessful() Some commands may want to provide information on whether the command was successful or not.
void	setFlags(Flag... flags) Add some flags to the command.
void	setFlags(Set<Flag> flags) Set the flags, replacing any existing flags.
void	setForwarded(boolean forwarded)
void	setMetadata(Metadata metadata) Sets metadata for this command.
void	setParams(Params params)
void	setTopologyId(int topologyId)
void	setValueMatcher(ValueMatcher valueMatcher)
boolean	shouldInvoke(InvocationContext ctx) Used by the InboundInvocationHandler to determine whether the command should be invoked or not.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

getAffectedKeys, isWriteOnly, updateStatusFromRemoteResponse

Methods inherited from interface org.infinispan.commands.VisitableCommand

acceptVisitor, alwaysReadsExistingValues, ignoreCommandOnStatus, readsExistingValues

Methods inherited from interface org.infinispan.commands.ReplicableCommand

canBlock, getCommandId, getParameters, isReturnValueExpected, perform, readFrom, setParameters, writeTo

Methods inherited from interface org.infinispan.commands.LocalFlagAffectedCommand

addFlag, addFlags

Constructor Detail

AbstractWriteManyCommand

public AbstractWriteManyCommand()

Method Detail

getTopologyId

public int getTopologyId()

Specified by:

getTopologyId in interface TopologyAffectedCommand

setTopologyId

public void setTopologyId(int topologyId)

Specified by:

setTopologyId in interface TopologyAffectedCommand

isForwarded

public boolean isForwarded()

setForwarded

public void setForwarded(boolean forwarded)

getValueMatcher

public ValueMatcher getValueMatcher()

Specified by:

getValueMatcher in interface WriteCommand

Returns:

The current value matching policy.

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: WriteCommand

Some commands may want to provide information on whether the command was successful or not. This is different from a failure, which usually would result in an exception being thrown. An example is a putIfAbsent() not doing anything because the key in question was present. This would result in a isSuccessful() call returning false.

Specified by:

isSuccessful in interface WriteCommand

Returns:

true if the command completed successfully, false otherwise.

isConditional

public boolean isConditional()

Description copied from interface: WriteCommand

Certain commands only work based on a certain condition or state of the cache. For example, 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.

Specified by:

isConditional in interface WriteCommand

Returns:

true if the command is conditional, false otherwise

shouldInvoke

public boolean shouldInvoke(InvocationContext ctx)

Description copied from interface: VisitableCommand

Used by the InboundInvocationHandler to determine whether the command should be invoked or not.

Specified by:

shouldInvoke in interface VisitableCommand

Returns:

true if the command should be invoked, false otherwise.

getFlags

public Set<Flag> getFlags()

Specified by:

getFlags in interface LocalFlagAffectedCommand

Returns:

The command flags - only valid to invoke after LocalFlagAffectedCommand.setFlags(java.util.Set). The set should not be modified directly, only via the LocalFlagAffectedCommand.setFlags(Set), LocalFlagAffectedCommand.addFlag(Flag) and LocalFlagAffectedCommand.addFlags(Set) methods.

getMetadata

public Metadata getMetadata()

Description copied from interface: MetadataAwareCommand

Get metadata of this command.

Specified by:

getMetadata in interface MetadataAwareCommand

Returns:

an instance of Metadata

setMetadata

public void setMetadata(Metadata metadata)

Description copied from interface: MetadataAwareCommand

Sets metadata for this command.

Specified by:

setMetadata in interface MetadataAwareCommand

setFlags

public void setFlags(Set<Flag> flags)

Description copied from interface: LocalFlagAffectedCommand

Set the flags, replacing any existing flags.

Specified by:

setFlags in interface LocalFlagAffectedCommand

Parameters:

flags - The new flags.

setFlags

public void setFlags(Flag... flags)

Description copied from interface: LocalFlagAffectedCommand

Add some flags to the command.

Specified by:

setFlags in interface LocalFlagAffectedCommand

Parameters:

flags - The flags to add.

hasFlag

public boolean hasFlag(Flag flag)

Description copied from interface: LocalFlagAffectedCommand

Check whether a particular flag is present in the command

Specified by:

hasFlag in interface LocalFlagAffectedCommand

Parameters:

flag - to lookup in the command

Returns:

true if the flag is present

getParams

public Params getParams()

Specified by:

getParams in interface ParamsCommand

setParams

public void setParams(Params params)