public final class WriteOnlyManyEntriesCommand<K,V> extends AbstractWriteManyCommand<K,V>
Modifier and Type | Field and Description |
---|---|
static byte |
COMMAND_ID |
Constructor and Description |
---|
WriteOnlyManyEntriesCommand() |
WriteOnlyManyEntriesCommand(Map<? extends K,? extends V> entries,
BiConsumer<V,EntryView.WriteEntryView<V>> f,
Params params) |
WriteOnlyManyEntriesCommand(WriteOnlyManyEntriesCommand<K,V> command) |
Modifier and Type | Method and Description |
---|---|
Object |
acceptVisitor(InvocationContext ctx,
Visitor visitor)
Accept a visitor, and return the result of accepting this visitor.
|
boolean |
alwaysReadsExistingValues() |
boolean |
canBlock()
If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.
|
Set<Object> |
getAffectedKeys() |
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
Map<? extends K,? extends V> |
getEntries() |
Set<? extends K> |
getKeys() |
boolean |
ignoreCommandOnStatus(ComponentStatus status)
Similar to
VisitableCommand.shouldInvoke(InvocationContext) but evaluated by InvocationContextInterceptor . |
boolean |
isReturnValueExpected()
If true, a return value will be provided when performed remotely.
|
boolean |
isWriteOnly()
Indicates whether the command is write-only, meaning that it makes no
attempt to read the previously associated value with key for which the
command is directed.
|
Object |
perform(InvocationContext ctx)
Performs the primary function of the command.
|
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput) . |
boolean |
readsExistingValues() |
void |
setEntries(Map<? extends K,? extends V> entries) |
void |
updateStatusFromRemoteResponse(Object remoteResponse)
Used for conditional commands, to update the status of the command on the originator
based on the result of its execution on the primary owner.
|
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput . |
getFlags, getMetadata, getParams, getTopologyId, getValueMatcher, hasFlag, isConditional, isForwarded, isSuccessful, setFlags, setFlags, setForwarded, setMetadata, setParams, setTopologyId, setValueMatcher, shouldInvoke
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getParameters, setParameters
addFlag, addFlags
public static final byte COMMAND_ID
public WriteOnlyManyEntriesCommand(Map<? extends K,? extends V> entries, BiConsumer<V,EntryView.WriteEntryView<V>> f, Params params)
public WriteOnlyManyEntriesCommand(WriteOnlyManyEntriesCommand<K,V> command)
public WriteOnlyManyEntriesCommand()
public byte getCommandId()
ReplicableCommand
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.output
- the stream.IOException
- if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.input
- the stream to read.IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.public Object perform(InvocationContext ctx) throws Throwable
ReplicableCommand
ctx
- invocation contextThrowable
- in the event of problems.public boolean isReturnValueExpected()
ReplicableCommand
ResponseGenerator
may choose to simply return null to save on marshalling costs.public boolean canBlock()
ReplicableCommand
true
if the command can block/wait, false
otherwisepublic Set<Object> getAffectedKeys()
public void updateStatusFromRemoteResponse(Object remoteResponse)
WriteCommand
public Object acceptVisitor(InvocationContext ctx, Visitor visitor) throws Throwable
VisitableCommand
ctx
- invocation contextvisitor
- visitor to acceptThrowable
- in the event of problemspublic boolean ignoreCommandOnStatus(ComponentStatus status)
VisitableCommand
VisitableCommand.shouldInvoke(InvocationContext)
but evaluated by InvocationContextInterceptor
.
Commands can opt to be discarded in case the cache status is not suited (as InvalidateCommand
)public boolean readsExistingValues()
true
if the command needs to read the previous values of the keys it acts on.public boolean alwaysReadsExistingValues()
true
if the command needs to read the previous values even on the backup owners.
In transactional caches, this refers to all the owners except the originator.public boolean isWriteOnly()
WriteCommand
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.