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

Author:

Bela Ban

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.util.SubmitToThreadPool

SubmitToThreadPool.BatchHandler, SubmitToThreadPool.SingleLoopbackHandler, SubmitToThreadPool.SingleMessageHandler, SubmitToThreadPool.SingleMessageHandlerWithClusterName

Field Summary

Fields inherited from class org.jgroups.util.SubmitToThreadPool

log, tp, tp_id

Constructor Summary

Constructors

Constructor	Description
PassRegularMessagesUpDirectly()

Method Summary

Modifier and Type	Method	Description
boolean	loopback(Message msg, boolean oob)	Process a message that was not received from the transport but from above (e.g.
boolean	process(Message msg, boolean oob)	Process a message received from the transport
boolean	process(MessageBatch batch, boolean oob)	Process a batch received from the transport

Methods inherited from class org.jgroups.util.SubmitToThreadPool

getTransport, init, removeAndDispatchNonBundledMessages

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jgroups.stack.MessageProcessingPolicy

destroy, reset

Constructor Detail

PassRegularMessagesUpDirectly

public PassRegularMessagesUpDirectly()

Method Detail

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: