org.openspaces.events.polling.receive

Class AbstractFifoGroupingReceiveOperationHandler

java.lang.Object

org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler

org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler

org.openspaces.events.polling.receive.AbstractFifoGroupingReceiveOperationHandler

All Implemented Interfaces:

ReceiveOperationHandler

Direct Known Subclasses:

ExclusiveReadReceiveOperationHandler, MultiExclusiveReadReceiveOperationHandler, MultiTakeReceiveOperationHandler, SingleTakeReceiveOperationHandler

public abstract class AbstractFifoGroupingReceiveOperationHandler
extends AbstractMemoryOnlySearchReceiveOperationHandler

Support class to perform receive operations with or without Fifo Grouping.

If configured to use Fifo Grouping, the read/take operation will use ReadModifiers.FIFO_GROUPING_POLL / TakeModifiers.FIFO_GROUPING_POLL accordingly.

Note:
• All the handlers that uses the Fifo Grouping capability should be used with a template that uses Fifo Grouping
• All the handlers that uses the Fifo Grouping capability must be performed under a transaction

Since:

9.0

Author:

yael

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	useFifoGrouping

Fields inherited from class org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler

useMemoryOnlySearch

Fields inherited from class org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler

nonBlocking, nonBlockingFactor

Constructor Summary

Constructors

Constructor and Description
AbstractFifoGroupingReceiveOperationHandler()

Method Summary

Modifier and Type	Method and Description
boolean	isUseFifoGrouping() Returns whether the handler is configured to use fifo grouping or not.
void	setUseFifoGrouping(boolean useFifoGrouping) Allows to configure the take/read operation to be performed in a Fifo Grouping manner.

Methods inherited from class org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler

isUseMemoryOnlySearch, setUseMemoryOnlySearch

Methods inherited from class org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler

doReceiveBlocking, doReceiveNonBlocking, receive, setNonBlocking, setNonBlockingFactor

Methods inherited from class java.lang.Object

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

Field Detail

useFifoGrouping

protected boolean useFifoGrouping

Constructor Detail

AbstractFifoGroupingReceiveOperationHandler

public AbstractFifoGroupingReceiveOperationHandler()

Method Detail

isUseFifoGrouping

public boolean isUseFifoGrouping()

Returns whether the handler is configured to use fifo grouping or not.

setUseFifoGrouping

public void setUseFifoGrouping(boolean useFifoGrouping)

Allows to configure the take/read operation to be performed in a Fifo Grouping manner.

Parameters:

useFifoGrouping - if true, will use ReadModifiers.FIFO_GROUPING_POLL / TakeModifiers.FIFO_GROUPING_POLL as read/take modifiers.