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

      • 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 void loopback​(Message msg,
                             boolean oob,
                             boolean internal)
        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
        internal - true if the message is internal
      • process

        public void process​(Message msg,
                            boolean oob,
                            boolean internal)
        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
        internal - true if the message is internal
      • process

        public void process​(MessageBatch batch,
                            boolean oob,
                            boolean internal)
        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
        internal - true if the batch contains only internal messages (or internal and OOB messages)
      • removeAndDispatchNonBundledMessages

        protected void removeAndDispatchNonBundledMessages​(MessageBatch oob_batch)
        Removes messages with flags DONT_BUNDLE and OOB set and executes them in the oob or internal thread pool. JGRP-1737