Class UnbatchOOBBatches

java.lang.Object

org.jgroups.util.SubmitToThreadPool

org.jgroups.util.MaxOneThreadPerSender

org.jgroups.util.UnbatchOOBBatches

All Implemented Interfaces:

Lifecycle, 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 MaxOneThreadPerSender

MaxOneThreadPerSender.Entry, MaxOneThreadPerSender.MessageTable

Nested classes/interfaces inherited from class SubmitToThreadPool

SubmitToThreadPool.BatchHandler, SubmitToThreadPool.SingleMessageHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected int	max_size

Fields inherited from class MaxOneThreadPerSender

batch_capacity, mcasts, queue_capacity, ucasts

Fields inherited from class SubmitToThreadPool

log, tp

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 MaxOneThreadPerSender

batchCapacity, batchCapacity, destroy, dump, loopback, loopback, process, queueCapacity, queueCapacity, reset, viewChange

Methods inherited from class SubmitToThreadPool

getTransport, init, removeAndDispatchNonBundledMessages

Methods inherited from class Object

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

Methods inherited from interface Lifecycle

init, start, stop

Field Details

max_size

protected int max_size

Constructor Details

UnbatchOOBBatches

public UnbatchOOBBatches()

Method Details

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: