Uses of Interface
org.jgroups.stack.MessageProcessingPolicy

Packages that use MessageProcessingPolicy

Package	Description
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of MessageProcessingPolicy in org.jgroups.protocols

Fields in org.jgroups.protocols declared as MessageProcessingPolicy

Modifier and Type	Field	Description
protected MessageProcessingPolicy	BaseBundler.msg_processing_policy
protected MessageProcessingPolicy	PerDestinationBundler.msg_processing_policy
protected MessageProcessingPolicy	TP.msg_processing_policy

Methods in org.jgroups.protocols that return MessageProcessingPolicy

Modifier and Type	Method	Description
MessageProcessingPolicy	TP.getMessageProcessingPolicy()
MessageProcessingPolicy	TP.msgProcessingPolicy()

Methods in org.jgroups.protocols with parameters of type MessageProcessingPolicy

Modifier and Type	Method	Description
<T extends TP> T	TP.msgProcessingPolicy(MessageProcessingPolicy p)

Uses of MessageProcessingPolicy in org.jgroups.util

Classes in org.jgroups.util that implement MessageProcessingPolicy

Modifier and Type	Class	Description
class	MaxOneThreadPerSender	MessageProcessingPolicy which processes regular messages and message batches by assigning a max of 1 thread per message from the same sender.
class	PassRegularMessagesUpDirectly	MessageProcessingPolicy which passes regular messages and message batches up directly (on the same thread), but passes OOB messages to the thread pool.
class	SubmitToThreadPool	Default message processing policy.
class	UnbatchOOBBatches	Same as MaxOneThreadPerSender, but for OOB message batches, every message of the batch is passed to the thread pool separately (https://issues.redhat.com/browse/JGRP-2800).

Method parameters in org.jgroups.util with type arguments of type MessageProcessingPolicy

Modifier and Type	Method	Description
static boolean	Tests.processingPolicyIs(java.lang.Class<? extends MessageProcessingPolicy> policy_class, JChannel... channels)