GigaSpaces XAP 9.7.2 API

org.openspaces.events.polling.receive
Class AbstractFifoGroupingReceiveOperationHandler

java.lang.Object
  extended by org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler
      extended by org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler
          extended by 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.

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.

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.