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 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
  
  All Methods Instance Methods Concrete Methods
  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, 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

- 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: