Class XSiteStateTransferControlCommand

  • All Implemented Interfaces:
    org.infinispan.commands.remote.CacheRpcCommand, org.infinispan.commands.ReplicableCommand

    public class XSiteStateTransferControlCommand
    extends XSiteReplicateCommand
    Command used to control the state transfer between sites.
    Since:
    7.0
    Author:
    Pedro Ruivo
    • Constructor Detail

      • XSiteStateTransferControlCommand

        public XSiteStateTransferControlCommand​(ByteString cacheName)
      • XSiteStateTransferControlCommand

        public XSiteStateTransferControlCommand()
    • 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.

        Throws:
        java.lang.Throwable
      • getCommandId

        public byte getCommandId()
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Used by marshallers to convert this command into an id for streaming.
        Returns:
        the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.
      • writeTo

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

        public void readFrom​(java.io.ObjectInput input)
                      throws java.io.IOException,
                             java.lang.ClassNotFoundException
        Description copied from interface: org.infinispan.commands.ReplicableCommand
        Reads this instance from the stream written by ReplicableCommand.writeTo(ObjectOutput).
        Parameters:
        input - the stream to read.
        Throws:
        java.io.IOException - if an error occurred during the I/O.
        java.lang.ClassNotFoundException - if it tries to load an undefined class.
      • 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.
        Returns:
        true or false
      • setStatusOk

        public void setStatusOk​(boolean statusOk)
      • setSiteName

        public void setSiteName​(java.lang.String siteName)
      • getSiteName

        public java.lang.String getSiteName()
      • setTopologyId

        public void setTopologyId​(int topologyId)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class org.infinispan.commands.remote.BaseRpcCommand