org.infinispan.commands.irac

Class IracUpdateKeyCommand

java.lang.Object

org.infinispan.commands.remote.BaseRpcCommand

org.infinispan.xsite.XSiteReplicateCommand

org.infinispan.commands.irac.IracUpdateKeyCommand

All Implemented Interfaces:

CacheRpcCommand, ReplicableCommand

Direct Known Subclasses:

IracClearKeysCommand, IracPutKeyCommand, IracRemoveKeyCommand

public abstract class IracUpdateKeyCommand
extends XSiteReplicateCommand

An update request that is sent to the remote site by IracManager.

Since:

11.0

Author:

Pedro Ruivo

Field Summary

Fields inherited from class org.infinispan.xsite.XSiteReplicateCommand

originSite

Fields inherited from class org.infinispan.commands.remote.BaseRpcCommand

cacheName, origin

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	IracUpdateKeyCommand(byte commandId, ByteString cacheName)

Method Summary

Modifier and Type	Method and Description
abstract IracUpdateKeyCommand	copyForCacheName(ByteString cacheName)
abstract CompletionStage<Void>	executeOperation(BackupReceiver receiver)
abstract Object	getKey()
CompletionStage<?>	invokeAsync(ComponentRegistry registry) Invoke the command asynchronously.
boolean	isClear()
boolean	isReturnValueExpected() If true, a return value will be provided when performed remotely.
CompletionStage<Void>	performInLocalSite(BackupReceiver receiver, boolean preserveOrder)

Methods inherited from class org.infinispan.xsite.XSiteReplicateCommand

getCommandId, setOriginSite

Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand

getCacheName, getOrigin, setOrigin, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.ReplicableCommand

canBlock, invoke, invokeAsync, isSuccessful, readFrom, writeTo

Constructor Detail

IracUpdateKeyCommand

protected IracUpdateKeyCommand(byte commandId,
                               ByteString cacheName)

Method Detail

performInLocalSite

public final CompletionStage<Void> performInLocalSite(BackupReceiver receiver,
                                                      boolean preserveOrder)

Specified by:

performInLocalSite in class XSiteReplicateCommand

invokeAsync

public final CompletionStage<?> invokeAsync(ComponentRegistry registry)

Description copied from interface: CacheRpcCommand

Invoke the command asynchronously.

This method replaces ReplicableCommand.invoke() for remote execution. The default implementation and ReplicableCommand.invoke() will be removed in future versions.

isReturnValueExpected

public final 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 XSiteReplicateCommand

Returns:

true or false

getKey

public abstract Object getKey()

executeOperation

public abstract CompletionStage<Void> executeOperation(BackupReceiver receiver)

copyForCacheName

public abstract IracUpdateKeyCommand copyForCacheName(ByteString cacheName)

isClear

public boolean isClear()