Package org.jgroups.util

Class PassRegularMessagesUpDirectly

java.lang.Object
org.jgroups.util.SubmitToThreadPool
org.jgroups.util.PassRegularMessagesUpDirectly
All Implemented Interfaces:
MessageProcessingPolicy
public class PassRegularMessagesUpDirectly extends SubmitToThreadPool
MessageProcessingPolicy which passes regular messages and message batches up directly (on the same thread), but passes OOB messages to the thread pool.
Since:
5.2.14

  • Constructor Details

    • PassRegularMessagesUpDirectly

      public PassRegularMessagesUpDirectly()

  • Method Details

    • 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
      Overrides:
      loopback in class SubmitToThreadPool
      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
      Overrides:
      process in class SubmitToThreadPool
      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
      Overrides:
      process in class SubmitToThreadPool
      Parameters:
      batch - the batch
      oob - true if the batch contains only OOB messages
      Returns: