org.openspaces.events.polling.receive
Class SingleTakeReceiveOperationHandler

java.lang.Object
  org.openspaces.events.polling.receive.AbstractNonBlockingReceiveOperationHandler
      org.openspaces.events.polling.receive.AbstractFifoGroupingReceiveOperationHandler
          org.openspaces.events.polling.receive.SingleTakeReceiveOperationHandler

All Implemented Interfaces:

ReceiveOperationHandler

public class SingleTakeReceiveOperationHandler
extends AbstractFifoGroupingReceiveOperationHandler

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

Author:

kimchy

Field Summary

Fields inherited from class org.openspaces.events.polling.receive.AbstractFifoGroupingReceiveOperationHandler

useFifoGrouping

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

nonBlocking, nonBlockingFactor

Constructor Summary

SingleTakeReceiveOperationHandler()

Method Summary

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()

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

isUseFifoGrouping, setUseFifoGrouping

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

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,int) 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,int) with no timeout.

Specified by:

doReceiveNonBlocking in class AbstractNonBlockingReceiveOperationHandler

Throws:

DataAccessException

toString

public String toString()

Overrides:

toString in class Object