Class SingleRpcCommand

    • Method Detail

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

        public Object perform​(InvocationContext ctx)
                       throws Throwable
        Description copied from interface: ReplicableCommand
        Performs the primary function of the command. Please see specific implementation classes for details on what is performed as well as return types. Important: this method will be invoked at the end of interceptors chain. It should never be called directly from a custom interceptor.
        Parameters:
        ctx - invocation context
        Returns:
        arbitrary return value generated by performing this command
        Throws:
        Throwable - in the event of problems.
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • 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.

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