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
    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.
        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.
        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.

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

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