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
TP. msg_processing_policy
Methods in org.jgroups.protocols that return MessageProcessingPolicy Modifier and Type Method Description MessageProcessingPolicy
TP. getMessageProcessingPolicy()
-
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 asMaxOneThreadPerSender
, 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)
-