Package 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 Details

    • useFifoGrouping

      protected boolean useFifoGrouping

  • Constructor Details

    • AbstractFifoGroupingReceiveOperationHandler

      public AbstractFifoGroupingReceiveOperationHandler()

  • Method Details

    • 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.