Class CacheTopologyControlCommand

  • All Implemented Interfaces:

    public class CacheTopologyControlCommand
    extends java.lang.Object
    implements org.infinispan.commands.ReplicableCommand
    A control command for all cache membership/rebalance operations. It is not a CacheRpcCommand because it needs to run on the coordinator even when the coordinator doesn't have a certain cache running.
    Dan Berindei
    • Method Detail

      • invokeAsync

        public java.util.concurrent.CompletableFuture<java.lang.Object> invokeAsync()
                                                                             throws java.lang.Throwable
        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
      • getCacheName

        public java.lang.String getCacheName()
      • getOrigin

        public Address getOrigin()
      • getTopologyId

        public int getTopologyId()
      • getThrowable

        public java.lang.Throwable getThrowable()
      • 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
        the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.
      • writeTo

        public void writeTo​( output)
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Writes this instance to the ObjectOutput.
        Specified by:
        writeTo in interface org.infinispan.commands.ReplicableCommand
        output - the stream.
        Throws: - if an error occurred during the I/O.
      • readFrom

        public void readFrom​( input)
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Reads this instance from the stream written by ReplicableCommand.writeTo(ObjectOutput).
        Specified by:
        readFrom in interface org.infinispan.commands.ReplicableCommand
        input - the stream to read.
        Throws: - if an error occurred during the I/O.
        java.lang.ClassNotFoundException - if it tries to load an undefined class.
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object
      • 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
        true or false
      • canBlock

        public boolean canBlock()
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool. Otherwise, the command is processed directly in the JGroups thread.

        This feature allows to avoid keep a JGroups thread busy that can originate discard of messages and retransmissions. So, the commands that can block (waiting for some state, acquiring locks, etc.) should return true.

        Specified by:
        canBlock in interface org.infinispan.commands.ReplicableCommand
        true if the command can block/wait, false otherwise