GigaSpaces XAP 9.7.2 API

org.openspaces.events.polling.receive
Class SingleReadReceiveOperationHandler

java.lang.Object
  extended by org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler
      extended by org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler
          extended by org.openspaces.events.polling.receive.SingleReadReceiveOperationHandler
All Implemented Interfaces:
ReceiveOperationHandler

public class SingleReadReceiveOperationHandler
extends AbstractMemoryOnlySearchReceiveOperationHandler

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

Author:
kimchy

Field Summary
 
Fields inherited from class org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler
useMemoryOnlySearch
 
Fields inherited from class org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler
nonBlocking, nonBlockingFactor
 
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.
 String toString()
           
 
Methods inherited from class org.openspaces.events.polling.receive.AbstractMemoryOnlySearchReceiveOperationHandler
isUseMemoryOnlySearch, setUseMemoryOnlySearch
 
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, 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

toString

public String toString()
Overrides:
toString in class Object

GigaSpaces XAP 9.7.2 API

Copyright © GigaSpaces.