Class XSiteStatePushCommand

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

    public class XSiteStatePushCommand
    extends org.infinispan.xsite.XSiteReplicateCommand<Void>
    Wraps the state to be sent to another site
    Since:
    7.0
    Author:
    Pedro Ruivo
    • Constructor Detail

      • XSiteStatePushCommand

        public XSiteStatePushCommand​(ByteString cacheName,
                                     XSiteState[] chunk,
                                     long timeoutMillis)
      • XSiteStatePushCommand

        public XSiteStatePushCommand​(ByteString cacheName)
      • XSiteStatePushCommand

        public XSiteStatePushCommand()
    • Method Detail

      • performInLocalSite

        public CompletionStage<Void> performInLocalSite​(org.infinispan.xsite.BackupReceiver receiver,
                                                        boolean preserveOrder)
      • getTimeout

        public long getTimeout()
      • getCommandId

        public byte getCommandId()
        Description copied from interface: 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.
      • 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
      • canBlock

        public boolean canBlock()
        Description copied from interface: 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.

        Returns:
        true if the command can block/wait, false otherwise
      • toString

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