GigaSpaces XAP 7.0 API

org.openspaces.events.polling.receive
Class SingleTakeReceiveOperationHandler

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

public class SingleTakeReceiveOperationHandler
extends AbstractNonBlockingReceiveOperationHandler

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

Author:
kimchy

Constructor Summary
SingleTakeReceiveOperationHandler()
           
 
Method Summary
protected  Object doReceiveBlocking(Object template, GigaSpace gigaSpace, long receiveTimeout)
          Performs a single take operation using GigaSpace.take(Object, long) with the given timeout.
protected  Object doReceiveNonBlocking(Object template, GigaSpace gigaSpace)
          Performs a single take operation using GigaSpace.take(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

SingleTakeReceiveOperationHandler

public SingleTakeReceiveOperationHandler()
Method Detail

doReceiveBlocking

protected Object doReceiveBlocking(Object template,
                                   GigaSpace gigaSpace,
                                   long receiveTimeout)
                            throws DataAccessException
Performs a single take operation using GigaSpace.take(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 a single take operation using GigaSpace.take(Object, long) with no timeout.

Specified by:
doReceiveNonBlocking in class AbstractNonBlockingReceiveOperationHandler
Throws:
DataAccessException

GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.