Class BaseRpcCommand

    • Field Detail

    • Constructor Detail

      • BaseRpcCommand

        protected BaseRpcCommand​(ByteString cacheName)
    • Method Detail

      • getCacheName

        public ByteString getCacheName()
        Specified by:
        getCacheName in interface CacheRpcCommand
        Returns:
        the name of the cache that produced this command. This will also be the name of the cache this command is intended for.
      • 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.

        Specified by:
        canBlock in interface ReplicableCommand
        Returns:
        true if the command can block/wait, false otherwise