public class SingleTakeReceiveOperationHandler extends AbstractFifoGroupingReceiveOperationHandler
GigaSpace.take(Object, long,
int).useFifoGroupinguseMemoryOnlySearchnonBlocking, nonBlockingFactor| Constructor and Description |
|---|
SingleTakeReceiveOperationHandler() |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
doReceiveBlocking(Object template,
GigaSpace gigaSpace,
long receiveTimeout)
Performs a single take operation using
GigaSpace.take(Object,
long, int) with the given timeout. |
protected Object |
doReceiveNonBlocking(Object template,
GigaSpace gigaSpace)
Performs a single take operation using
GigaSpace.take(Object,
long, int) with no timeout. |
String |
toString() |
isUseFifoGrouping, setUseFifoGroupingisUseMemoryOnlySearch, setUseMemoryOnlySearchreceive, setNonBlocking, setNonBlockingFactorprotected Object doReceiveBlocking(Object template, GigaSpace gigaSpace, long receiveTimeout) throws org.springframework.dao.DataAccessException
GigaSpace.take(Object,
long, int) with the given timeout.doReceiveBlocking in class AbstractNonBlockingReceiveOperationHandlerorg.springframework.dao.DataAccessExceptionprotected Object doReceiveNonBlocking(Object template, GigaSpace gigaSpace) throws org.springframework.dao.DataAccessException
GigaSpace.take(Object,
long, int) with no timeout.doReceiveNonBlocking in class AbstractNonBlockingReceiveOperationHandlerorg.springframework.dao.DataAccessExceptionCopyright © GigaSpaces.