public abstract class BackupWriteCommand extends BaseRpcCommand
This is a base command with the CommandInvocationId
, topology and flags.
Since the primary → backup operations are ordered by segment, it contains the segment to be updated and its sequence number.
Modifier and Type | Field and Description |
---|---|
protected int |
segmentId |
cacheName, origin
Modifier and Type | Method and Description |
---|---|
boolean |
canBlock()
If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.
|
CommandInvocationId |
getCommandInvocationId() |
long |
getFlags() |
int |
getSegmentId() |
long |
getSequence() |
int |
getTopologyId() |
CompletionStage<?> |
invokeAsync(ComponentRegistry componentRegistry)
Invoke the command asynchronously.
|
boolean |
isReturnValueExpected()
If true, a return value will be provided when performed remotely.
|
void |
setSegmentId(int segmentId) |
void |
setSequence(long sequence) |
getCacheName, getOrigin, setOrigin, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getCommandId, invoke, invokeAsync, isSuccessful, readFrom, writeTo
public final CompletionStage<?> invokeAsync(ComponentRegistry componentRegistry)
CacheRpcCommand
This method replaces ReplicableCommand.invoke()
for remote execution.
The default implementation and ReplicableCommand.invoke()
will be removed in future versions.
public final boolean isReturnValueExpected()
ReplicableCommand
ResponseGenerator
may choose to simply return null to save on marshalling
costs.public final boolean canBlock()
ReplicableCommand
true
if the command can block/wait, false
otherwisepublic final long getSequence()
public final void setSequence(long sequence)
public final CommandInvocationId getCommandInvocationId()
public final int getTopologyId()
public final long getFlags()
public final int getSegmentId()
public final void setSegmentId(int segmentId)
Copyright © 2021 JBoss by Red Hat. All rights reserved.