Class AffinityUpdateCommand

  • All Implemented Interfaces:
    org.infinispan.commands.remote.CacheRpcCommand, org.infinispan.commands.ReplicableCommand, org.infinispan.query.impl.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
    • Constructor Detail

      • AffinityUpdateCommand

        public AffinityUpdateCommand​(ByteString cacheName)
    • Method Detail

      • invokeAsync

        public java.util.concurrent.CompletableFuture<java.lang.Object> invokeAsync()
        Description copied from interface: org.infinispan.commands.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 org.infinispan.commands.ReplicableCommand
        Specified by:
        invokeAsync in class AbstractUpdateCommand
      • getCommandId

        public byte getCommandId()
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Used by marshallers to convert this command into an id for streaming.
        Specified by:
        getCommandId in interface org.infinispan.commands.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: org.infinispan.commands.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 org.infinispan.commands.ReplicableCommand
        Overrides:
        isReturnValueExpected in class AbstractUpdateCommand
        Returns:
        true or false