Package org.jgroups.util

Class UnbatchOOBBatches

java.lang.Object

org.jgroups.util.SubmitToThreadPool

org.jgroups.util.MaxOneThreadPerSender

org.jgroups.util.UnbatchOOBBatches

All Implemented Interfaces:

MessageProcessingPolicy

public class UnbatchOOBBatches
extends MaxOneThreadPerSender

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).

Since:

5.4, 5.3.7

Author:

Bela Ban

Nested Class Summary

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

MaxOneThreadPerSender.BatchHandlerLoop, MaxOneThreadPerSender.Entry, MaxOneThreadPerSender.MessageTable

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

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

Field Summary

Fields

Modifier and Type	Field	Description
protected int	max_size

Fields inherited from class org.jgroups.util.MaxOneThreadPerSender

max_buffer_size, mcasts, ucasts

Fields inherited from class org.jgroups.util.SubmitToThreadPool

log, tp, tp_id

Constructor Summary

Constructors

Constructor	Description
UnbatchOOBBatches()

Method Summary

Modifier and Type	Method	Description
boolean	process(MessageBatch batch, boolean oob)	Process a batch received from the transport

Methods inherited from class org.jgroups.util.MaxOneThreadPerSender

destroy, dump, init, loopback, loopback, process, reset, viewChange

Methods inherited from class org.jgroups.util.SubmitToThreadPool

getTransport, removeAndDispatchNonBundledMessages

Methods inherited from class java.lang.Object

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

Field Detail

max_size

protected int max_size

Constructor Detail

UnbatchOOBBatches

public UnbatchOOBBatches()

Method Detail

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 MaxOneThreadPerSender

Parameters:

batch - the batch

oob - true if the batch contains only OOB messages

Returns: