org.openspaces.events.polling.receive
Class AbstractFifoGroupsReceiveOperationHandler

java.lang.Object
  org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler
      org.openspaces.events.polling.receive.AbstractFifoGroupsReceiveOperationHandler

All Implemented Interfaces:

ReceiveOperationHandler

public abstract class AbstractFifoGroupsReceiveOperationHandler
extends AbstractNonBlockingReceiveOperationHandler

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

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

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

Since:

9.0

Author:

yael

Field Summary

protected boolean

fifoGroups

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

nonBlocking, nonBlockingFactor

Constructor Summary

AbstractFifoGroupsReceiveOperationHandler()

Method Summary

boolean	isFifoGroups()
void	setFifoGroups(boolean fifoGroups) Allows to configure the take/read operation to be performed in a Fifo Groups manner.

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

fifoGroups

protected boolean fifoGroups

Constructor Detail

AbstractFifoGroupsReceiveOperationHandler

public AbstractFifoGroupsReceiveOperationHandler()

Method Detail

isFifoGroups

public boolean isFifoGroups()

setFifoGroups

public void setFifoGroups(boolean fifoGroups)

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

Parameters:

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