org.openspaces.events.polling.receive
Class SingleReadReceiveOperationHandler

java.lang.Object
  org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler
      org.openspaces.events.polling.receive.SingleReadReceiveOperationHandler

All Implemented Interfaces:

ReceiveOperationHandler

public class SingleReadReceiveOperationHandler
extends AbstractNonBlockingReceiveOperationHandler

Performs single read operation using GigaSpace.read(Object,long).

Author:

kimchy

Constructor Summary

SingleReadReceiveOperationHandler()

Method Summary

protected Object	doReceiveBlocking(Object template, GigaSpace gigaSpace, long receiveTimeout) Performs single read operation using GigaSpace.read(Object,long) with the given timeout.
protected Object	doReceiveNonBlocking(Object template, GigaSpace gigaSpace) Performs single read operation using GigaSpace.read(Object,long) with no timeout.

Methods inherited from class org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler

receive, setNonBlocking, setNonBlockingFactor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SingleReadReceiveOperationHandler

public SingleReadReceiveOperationHandler()

Method Detail

doReceiveBlocking

protected Object doReceiveBlocking(Object template,
                                   GigaSpace gigaSpace,
                                   long receiveTimeout)
                            throws DataAccessException

Performs single read operation using GigaSpace.read(Object,long) with the given timeout.

Specified by:

doReceiveBlocking in class AbstractNonBlockingReceiveOperationHandler

Throws:

DataAccessException

doReceiveNonBlocking

protected Object doReceiveNonBlocking(Object template,
                                      GigaSpace gigaSpace)
                               throws DataAccessException

Performs single read operation using GigaSpace.read(Object,long) with no timeout.

Specified by:

doReceiveNonBlocking in class AbstractNonBlockingReceiveOperationHandler

Throws:

DataAccessException