Class XSiteStateTransferRestartSendingCommand

java.lang.Object
org.infinispan.commands.remote.BaseRpcCommand
org.infinispan.xsite.commands.XSiteStateTransferRestartSendingCommand
All Implemented Interfaces:
org.infinispan.commands.remote.CacheRpcCommand, ReplicableCommand, TracedCommand, VersionAware

@ProtoTypeId(1272) public class XSiteStateTransferRestartSendingCommand extends org.infinispan.commands.remote.BaseRpcCommand
Restart sending XSite state.
Since:
11.0
Author:
Ryan Emerson
  • Constructor Details

    • XSiteStateTransferRestartSendingCommand

      @ProtoFactory public XSiteStateTransferRestartSendingCommand(ByteString cacheName, String siteName, int topologyId)
  • Method Details

    • invokeAsync

      public CompletionStage<?> invokeAsync(ComponentRegistry registry)
    • 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.
      Returns:
      true or false
    • supportedSince

      public NodeVersion supportedSince()
      Description copied from interface: ReplicableCommand
      Returns a NodeVersion representing the Infinispan version in which this command was added. This value is used to ensure that when the cluster contains different Infinispan versions, only commands compatible with the oldest version are transmitted.

      Abstract classes should not implement this method as the version should be specific to an individual implementation. Similarly, implementations which extend another ReplicableCommand should always override this method.

      Returns:
      a NodeVersion corresponding to the Infinispan version this command was added.
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • invokeLocal

      public void invokeLocal(XSiteStateProvider provider)