org.openspaces.events.asyncpolling.receive

Class ExclusiveReadAsyncOperationHandler

java.lang.Object

org.openspaces.events.asyncpolling.receive.ExclusiveReadAsyncOperationHandler

All Implemented Interfaces:

AsyncOperationHandler

public class ExclusiveReadAsyncOperationHandler
extends Object
implements AsyncOperationHandler

Performs a single take usign GigaSpace.asyncRead(Object) under exclusive read lock.

Author:

kimchy

Constructor Summary

Constructors

Constructor and Description
ExclusiveReadAsyncOperationHandler()

Method Summary

Modifier and Type	Method and Description
AsyncFuture	asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncRead(Object) under exclusive read lock.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExclusiveReadAsyncOperationHandler

public ExclusiveReadAsyncOperationHandler()

Method Detail

asyncReceive

public AsyncFuture asyncReceive(Object template,
                                GigaSpace gigaSpace,
                                long receiveTimeout,
                                AsyncFutureListener listener)
                         throws org.springframework.dao.DataAccessException

Performs a single take usign GigaSpace.asyncRead(Object) under exclusive read lock.

Specified by:

asyncReceive in interface AsyncOperationHandler

Throws:

org.springframework.dao.DataAccessException