Class SubmitToThreadPool

    • Field Detail

      • tp

        protected TP tp
      • tp_id

        protected short tp_id
      • log

        protected Log log
    • Constructor Detail

      • SubmitToThreadPool

        public SubmitToThreadPool()
    • Method Detail

      • getTransport

        protected TP getTransport()
      • init

        public void init​(TP transport)
        Description copied from interface: MessageProcessingPolicy
        Called after creation. Implementations may want to cache the transport reference to get access to thread pools, message counters etc
        Specified by:
        init in interface MessageProcessingPolicy
      • loopback

        public boolean loopback​(Message msg,
                                boolean oob)
        Description copied from interface: MessageProcessingPolicy
        Process a message that was not received from the transport but from above (e.g. the channel or a protocol), and needs to be looped back up because (1) the destination address is null (every multicast message is looped back) or (2) the destination address is the sender's address (unicast message to self).
        A message that is looped back can bypass cluster name matching.
        Specified by:
        loopback in interface MessageProcessingPolicy
        Parameters:
        msg - the message to be looped back up the stack.
        oob - true if the message is an OOB message
        Returns:
      • process

        public boolean process​(Message msg,
                               boolean oob)
        Description copied from interface: MessageProcessingPolicy
        Process a message received from the transport
        Specified by:
        process in interface MessageProcessingPolicy
        Parameters:
        msg - the message
        oob - true if the message is an OOB message
        Returns:
      • process

        public boolean process​(MessageBatch batch,
                               boolean oob)
        Description copied from interface: MessageProcessingPolicy
        Process a batch received from the transport
        Specified by:
        process in interface MessageProcessingPolicy
        Parameters:
        batch - the batch
        oob - true if the batch contains only OOB messages
        Returns:
      • removeAndDispatchNonBundledMessages

        protected boolean removeAndDispatchNonBundledMessages​(MessageBatch oob_batch,
                                                              boolean loopback)
        Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool. JGRP-1737 Returns true if at least one message was removed