public class ExclusiveReadReceiveOperationHandler extends AbstractFifoGroupingReceiveOperationHandler
GigaSpace.read(Object, long,
ReadModifiers) under an exclusive read lock. This receive operation handler allows to lock entries so
other receive operations won't be able to obtain it (mimics the take operation) but without
actually performing a take from the Space.
Note, this receive operation handler must be performed under a transaction.useFifoGroupinguseMemoryOnlySearchnonBlocking, nonBlockingFactor| Constructor and Description |
|---|
ExclusiveReadReceiveOperationHandler() |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs single read operation using
GigaSpace.read(Object, long,
ReadModifiers) under an exclusive read lock. |
protected Object |
doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs single read operation using
GigaSpace.read(Object, long,
ReadModifiers) under an exclusive read lock with no timeout. |
String |
toString() |
isUseFifoGrouping, setUseFifoGroupingisUseMemoryOnlySearch, setUseMemoryOnlySearchreceive, setNonBlocking, setNonBlockingFactorpublic ExclusiveReadReceiveOperationHandler()
protected Object doReceiveBlocking(Object template, GigaSpace gigaSpace, long receiveTimeout) throws org.springframework.dao.DataAccessException
GigaSpace.read(Object, long,
ReadModifiers) under an exclusive read lock. This receive operation handler allows to lock entries so
other receive operations won't be able to obtain it (mimics the take operation) but without
actually performing a take from the Space.
Note, this receive operation handler must be performed under a transaction.doReceiveBlocking in class AbstractNonBlockingReceiveOperationHandlerorg.springframework.dao.DataAccessExceptionprotected Object doReceiveNonBlocking(Object template, GigaSpace gigaSpace) throws org.springframework.dao.DataAccessException
GigaSpace.read(Object, long,
ReadModifiers) under an exclusive read lock with no timeout. This receive operation handler allows to
lock entries so other receive operations won't be able to obtain it (mimics the take
operation) but without actually performing a take from the Space.
Note, this receive operation handler must be performed under a transaction.doReceiveNonBlocking in class AbstractNonBlockingReceiveOperationHandlerorg.springframework.dao.DataAccessExceptionCopyright © GigaSpaces.