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

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

AbstractFifoGroupingReceiveOperationHandler()

Method Summary

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.