Package org.infinispan.query.affinity

Class AffinityUpdateCommand

java.lang.Object

org.infinispan.commands.remote.BaseRpcCommand

org.infinispan.query.indexmanager.AbstractUpdateCommand

org.infinispan.query.affinity.AffinityUpdateCommand

All Implemented Interfaces:

org.infinispan.commands.remote.CacheRpcCommand, ReplicableCommand, CustomQueryCommand

public class AffinityUpdateCommand
extends AbstractUpdateCommand

Handle index updates forwarded by the AffinityIndexManager, in exceptional cases where an index work ceases to be local to a node due to transient ownership changes.

Since:

9.0

Field Summary

Fields

Modifier and Type	Field	Description
static byte	COMMAND_ID

Fields inherited from class org.infinispan.query.indexmanager.AbstractUpdateCommand

indexName, queryInterceptor, searchFactory, serializedModel

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

cacheName

Constructor Summary

Constructors

Constructor	Description
AffinityUpdateCommand(ByteString cacheName)

Method Summary

Modifier and Type	Method	Description
byte	getCommandId()	Used by marshallers to convert this command into an id for streaming.
CompletableFuture<Object>	invokeAsync()	Invoke the command asynchronously.
boolean	isReturnValueExpected()	If true, a return value will be provided when performed remotely.
void	setSerializedWorkList(byte[] serializedModel)

Methods inherited from class org.infinispan.query.indexmanager.AbstractUpdateCommand

canBlock, getIndexName, readFrom, setCacheManager, setIndexName, writeTo

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.remote.CacheRpcCommand

getCacheName, getOrigin, setOrigin

Methods inherited from interface org.infinispan.commands.ReplicableCommand

invoke, isSuccessful, perform

Field Detail

COMMAND_ID

public static final byte COMMAND_ID

See Also:

Constant Field Values

Constructor Detail

AffinityUpdateCommand

public AffinityUpdateCommand(ByteString cacheName)

Method Detail

setSerializedWorkList

public void setSerializedWorkList(byte[] serializedModel)

Overrides:

setSerializedWorkList in class AbstractUpdateCommand

invokeAsync

public CompletableFuture<Object> invokeAsync()

Description copied from interface: ReplicableCommand

Invoke the command asynchronously.

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

Specified by:

invokeAsync in interface ReplicableCommand

Specified by:

invokeAsync in class AbstractUpdateCommand

getCommandId

public byte getCommandId()

Description copied from interface: ReplicableCommand

Used by marshallers to convert this command into an id for streaming.

Specified by:

getCommandId in interface ReplicableCommand

Specified by:

getCommandId in class AbstractUpdateCommand

Returns:

the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.

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 AbstractUpdateCommand

Returns:

true or false