Package org.openspaces.events.polling.receive

package org.openspaces.events.polling.receive

An abstraction on top of the actual receive operation performed by the polling event container. Includes built in implementation for it.

Related Packages

Package	Description
org.openspaces.events.polling	A polling event container generating events by performing polling receive operations.
org.openspaces.events.polling.config
org.openspaces.events.polling.trigger	An abstraction on top of the trigger operation performed before the initiation of transactional receive operation.

Class	Description
AbstractFifoGroupingReceiveOperationHandler	Support class to perform receive operations with or without Fifo Grouping.
AbstractMemoryOnlySearchReceiveOperationHandler	Support class to perform receive operations with or without memory only search..
AbstractNonBlockingReceiveOperationHandler	Support class to perform either non blocking or blocking receive operation.
ExclusiveReadReceiveOperationHandler	Performs single read operation using GigaSpace.read(Object, long, ReadModifiers) under an exclusive read lock.
MultiExclusiveReadReceiveOperationHandler	First tries and perform a GigaSpace.readMultiple(Object, int, ReadModifiers) using the provided template, configured maxEntries (defaults to 50) and the configured fifoGroups (default to false).
MultiReadReceiveOperationHandler	First tries and perform a GigaSpace.readMultiple(Object, int) using the provided template and configured maxEntries (defaults to 50).
MultiTakeReceiveOperationHandler	First tries and perform a GigaSpace.takeMultiple(Object, int, TakeModifiers) using the provided template, the configured maxEntries (defaults to 50) and the configured fifoGroups (default to false).
ReceiveOperationHandler	Perform the actual receive operations for SimplePollingEventListenerContainer.
SingleReadReceiveOperationHandler	Performs single read operation using GigaSpace.read(Object, long).
SingleTakeReceiveOperationHandler	Performs single take operation using GigaSpace.take(Object, long, TakeModifiers).