| Package | Description | 
|---|---|
| com.gigaspaces.async | 
 Provides GigaSpaces asynchronous operations related interfaces. 
 | 
| com.gigaspaces.async.internal | |
| com.gigaspaces.internal.client.cache.localcache.actions | |
| com.gigaspaces.internal.client.cache.localview.actions | |
| com.gigaspaces.internal.client.spaceproxy | |
| com.gigaspaces.internal.client.spaceproxy.actions | |
| com.gigaspaces.internal.client.spaceproxy.executors | |
| com.gigaspaces.internal.cluster.node.impl.router | |
| com.gigaspaces.internal.cluster.node.impl.router.spacefinder | |
| com.gigaspaces.internal.remoting | |
| com.gigaspaces.internal.remoting.routing.partitioned | |
| com.gigaspaces.lrmi.nio.async | |
| org.openspaces.core | 
 Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and
the ability to create it. 
 | 
| org.openspaces.core.executor.juc | |
| org.openspaces.core.internal | |
| org.openspaces.core.transaction.internal | |
| org.openspaces.events.asyncpolling.receive | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SettableFuture<T>
Created by Barak Bar Orion 19/08/14. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <T,R> AsyncFuture<R> | 
FutureFactory.create(AsyncFuture<T>[] futures,
      AsyncResultsReducer<T,R> reducer)  | 
static <T,R> AsyncFuture<R> | 
FutureFactory.create(AsyncFuture<T>[] futures,
      AsyncResultsReducer<T,R> reducer,
      AsyncResultFilter<T> moderator)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T,R> AsyncFuture<R> | 
FutureFactory.create(AsyncFuture<T>[] futures,
      AsyncResultsReducer<T,R> reducer)  | 
static <T,R> AsyncFuture<R> | 
FutureFactory.create(AsyncFuture<T>[] futures,
      AsyncResultsReducer<T,R> reducer,
      AsyncResultFilter<T> moderator)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractFuture<T>  | 
class  | 
CompoundFuture<T,R>
a future implementation used to aggregate results from multiple Futures. 
 | 
| Constructor and Description | 
|---|
CompoundFuture(AsyncFuture<T>[] futures,
              AsyncResultsReducer<T,R> reducer)  | 
CompoundFuture(AsyncFuture<T>[] futures,
              AsyncResultsReducer<T,R> reducer,
              AsyncResultFilter<T> moderator)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LocalCacheImplAsyncOperationsFuture<T>
Base class for dcache async futures, it registers with a custom listener per implementation and
 delegates the result to the user supplied listener when the operation is considered done (Up to
 the custom listener) 
 | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture<AddTypeIndexesResult> | 
LocalCacheImplTypeDescriptorActionsExecutor.asyncAddIndexes(LocalCacheContainer spaceProxy,
               AddTypeIndexesRequestInfo requestInfo)  | 
AsyncFuture<?> | 
LocalCacheImplReadTakeAction.asyncRead(LocalCacheContainer spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
AsyncFuture<?> | 
LocalCacheImplReadTakeAction.asyncTake(LocalCacheContainer spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
AsyncFuture | 
LocalCacheImplAdminAction.execute(LocalCacheContainer spaceProxy,
       SpaceTask task,
       Object routing,
       Transaction txn,
       AsyncFutureListener listener)  | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture<AddTypeIndexesResult> | 
LocalViewImplTypeDescriptorActionsExecutor.asyncAddIndexes(LocalViewContainer spaceProxy,
               AddTypeIndexesRequestInfo requestInfo)  | 
AsyncFuture<?> | 
LocalViewImplReadTakeAction.asyncRead(LocalViewContainer spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
AsyncFuture<?> | 
LocalViewImplReadTakeAction.asyncTake(LocalViewContainer spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
AsyncFuture | 
LocalViewImplAdminAction.execute(LocalViewContainer spaceProxy,
       SpaceTask task,
       Object routing,
       Transaction txn,
       AsyncFutureListener listener)  | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture<AddTypeIndexesResult> | 
ISpaceProxy.asyncAddIndexes(String typeName,
               SpaceIndex[] indexes,
               AsyncFutureListener<AddTypeIndexesResult> listener)  | 
AsyncFuture<AddTypeIndexesResult> | 
AbstractSpaceProxy.asyncAddIndexes(String typeName,
               SpaceIndex[] indexes,
               AsyncFutureListener<AddTypeIndexesResult> listener)  | 
AsyncFuture | 
ISpaceProxy.asyncRead(Object template,
         Transaction transaction,
         long timeout,
         int modifiers,
         AsyncFutureListener listener)
Internal methods only. 
 | 
AsyncFuture<?> | 
AbstractSpaceProxy.asyncRead(Object template,
         Transaction txn,
         long timeout,
         int modifiers,
         AsyncFutureListener listener)  | 
AsyncFuture | 
ISpaceProxy.asyncTake(Object template,
         Transaction transaction,
         long timeout,
         int modifiers,
         AsyncFutureListener listener)
Internal methods only. 
 | 
AsyncFuture<?> | 
AbstractSpaceProxy.asyncTake(Object template,
         Transaction txn,
         long timeout,
         int modifiers,
         AsyncFutureListener listener)  | 
AsyncFuture | 
ISpaceProxy.execute(SpaceTask task,
       Object routing,
       Transaction tx,
       AsyncFutureListener listener)
Executes a task on a single space. 
 | 
AsyncFuture | 
AbstractSpaceProxy.execute(SpaceTask task,
       Object routing,
       Transaction tx,
       AsyncFutureListener listener)  | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture<AddTypeIndexesResult> | 
AbstractSpaceProxyActionManager.asyncAddIndexes(String typeName,
               SpaceIndex[] indexes,
               AsyncFutureListener<AddTypeIndexesResult> listener)  | 
AsyncFuture<?> | 
AbstractSpaceProxyActionManager.asyncRead(Object template,
         Transaction txn,
         long timeout,
         int modifiers,
         AsyncFutureListener<?> listener)  | 
AsyncFuture<?> | 
SpaceProxyImplReadTakeAction.asyncRead(SpaceProxyImpl spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
abstract AsyncFuture<?> | 
ReadTakeProxyAction.asyncRead(TSpaceProxy spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
AsyncFuture<?> | 
AbstractSpaceProxyActionManager.asyncTake(Object template,
         Transaction txn,
         long timeout,
         int modifiers,
         AsyncFutureListener<?> listener)  | 
AsyncFuture<?> | 
SpaceProxyImplReadTakeAction.asyncTake(SpaceProxyImpl spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
abstract AsyncFuture<?> | 
ReadTakeProxyAction.asyncTake(TSpaceProxy spaceProxy,
         ReadTakeAsyncProxyActionInfo actionInfo)  | 
AsyncFuture | 
SpaceProxyImplAdminAction.execute(SpaceProxyImpl spaceProxy,
       SpaceTask task,
       Object routing,
       Transaction txn,
       AsyncFutureListener listener)  | 
abstract AsyncFuture | 
AdminProxyAction.execute(TSpaceProxy spaceProxy,
       SpaceTask task,
       Object routing,
       Transaction txn,
       AsyncFutureListener listener)  | 
AsyncFuture | 
AbstractSpaceProxyActionManager.executeTask(SpaceTask task,
           Object routing,
           Transaction tx,
           AsyncFutureListener listener)  | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture<AddTypeIndexesResult> | 
SpaceProxyImplTypeDescriptorActionsExecutor.asyncAddIndexes(SpaceProxyImpl spaceProxy,
               AddTypeIndexesRequestInfo requestInfo)  | 
abstract AsyncFuture<AddTypeIndexesResult> | 
TypeDescriptorActionsProxyExecutor.asyncAddIndexes(TSpaceProxy spaceProxy,
               AddTypeIndexesRequestInfo requestInfo)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> AsyncFuture<T> | 
IReplicationConnection.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
<TR> AsyncFuture<TR> | 
AbstractProxyBasedReplicationMonitoredConnection.dispatchAsync(AbstractReplicationPacket<TR> packet)  | 
<T> AsyncFuture<T> | 
IAsyncContextProvider.getFutureContext(T syncResult,
                Object proxy)  | 
<T> AsyncFuture<T> | 
LRMIAsyncContextProvider.getFutureContext(T syncResult,
                Object proxy)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> AsyncFuture<T> | 
ConnectionReference.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
RemoteOperationFutureListener<T extends RemoteOperationResult>  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BroadcastOperationFutureListener<T extends RemoteOperationResult>  | 
class  | 
ScatterGatherOperationFutureListener<T extends RemoteOperationResult>  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
IFuture<T>
An internal interface extending the  
AsyncFuture. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LRMIFuture<T>
A future implementation used to hold delayed result coming from one target. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture<AddTypeIndexesResult> | 
GigaSpaceTypeManager.asyncAddIndex(String typeName,
             SpaceIndex index)
Adds the specified index to the specified type. 
 | 
AsyncFuture<AddTypeIndexesResult> | 
DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName,
             SpaceIndex index)  | 
AsyncFuture<AddTypeIndexesResult> | 
GigaSpaceTypeManager.asyncAddIndex(String typeName,
             SpaceIndex index,
             AsyncFutureListener<AddTypeIndexesResult> listener)
Adds the specified index to the specified type. 
 | 
AsyncFuture<AddTypeIndexesResult> | 
DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName,
             SpaceIndex index,
             AsyncFutureListener<AddTypeIndexesResult> listener)  | 
AsyncFuture<AddTypeIndexesResult> | 
GigaSpaceTypeManager.asyncAddIndexes(String typeName,
               SpaceIndex[] indexes,
               AsyncFutureListener<AddTypeIndexesResult> listener)
Adds the specified indexes to the specified type. 
 | 
AsyncFuture<AddTypeIndexesResult> | 
DefaultGigaSpaceTypeManager.asyncAddIndexes(String typeName,
               SpaceIndex[] indexes,
               AsyncFutureListener<AddTypeIndexesResult> listener)  | 
AsyncFuture<SpaceDataSourceLoadResult> | 
DefaultGigaSpace.asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest)  | 
AsyncFuture<SpaceDataSourceLoadResult> | 
GigaSpace.asyncLoad(SpaceDataSourceLoadRequest spaceDataSourceLoadRequest)
Loads data from a  
SpaceDataSource on demand
 The Space data source is created with SpaceDataSourceFactory
 Loaded data can be adapted using the SpaceTypeSchemaAdapter | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(ISpaceQuery<T> template)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(ISpaceQuery<T> template,
         AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout,
         AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout,
         ReadModifiers modifiers)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout,
         ReadModifiers modifiers)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout,
         ReadModifiers modifiers,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(ISpaceQuery<T> template,
         long timeout,
         ReadModifiers modifiers,
         AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(T template)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(T template)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(T template,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(T template,
         AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(T template,
         long timeout)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(T template,
         long timeout)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(T template,
         long timeout,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(T template,
         long timeout,
         AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(T template,
         long timeout,
         ReadModifiers modifiers)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(T template,
         long timeout,
         ReadModifiers modifiers)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncRead(T template,
         long timeout,
         ReadModifiers modifiers,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncRead(T template,
         long timeout,
         ReadModifiers modifiers,
         AsyncFutureListener<T> listener)
Reads any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(ISpaceQuery<T> template)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(ISpaceQuery<T> template,
         AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout,
         AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout,
         TakeModifiers modifiers)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout,
         TakeModifiers modifiers)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout,
         TakeModifiers modifiers,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(ISpaceQuery<T> template,
         long timeout,
         TakeModifiers modifiers,
         AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(T template)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(T template)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(T template,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(T template,
         AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(T template,
         long timeout)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(T template,
         long timeout)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(T template,
         long timeout,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(T template,
         long timeout,
         AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(T template,
         long timeout,
         TakeModifiers modifiers)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(T template,
         long timeout,
         TakeModifiers modifiers)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.asyncTake(T template,
         long timeout,
         TakeModifiers modifiers,
         AsyncFutureListener<T> listener)  | 
<T> AsyncFuture<T> | 
GigaSpace.asyncTake(T template,
         long timeout,
         TakeModifiers modifiers,
         AsyncFutureListener<T> listener)
Take (remove) any matching entry from the space in an asynchronous manner. 
 | 
<T extends Serializable,R> | 
DefaultGigaSpace.distExecute(DistributedTask<T,R> task,
           AsyncFutureListener<R> listener)  | 
AsyncFuture<R> | 
ExecutorBuilder.execute()
Executes all the given tasks (asynchronously) based on their execution mode and returns a
 future allowing to retrieve the reduced operation of all the tasks. 
 | 
<T extends Serializable,R> | 
DefaultGigaSpace.execute(DistributedTask<T,R> task)  | 
<T extends Serializable,R> | 
GigaSpace.execute(DistributedTask<T,R> task)
Executes the task on all the primary space nodes within the cluster (broadcast). 
 | 
<T extends Serializable,R> | 
DefaultGigaSpace.execute(DistributedTask<T,R> task,
       AsyncFutureListener<R> listener)  | 
<T extends Serializable,R> | 
DefaultGigaSpace.execute(DistributedTask<T,R> task,
       Object... routings)  | 
<T extends Serializable,R> | 
GigaSpace.execute(DistributedTask<T,R> task,
       Object... routing)
Executes a task on all the nodes that correspond to the list of routing values. 
 | 
<T extends Serializable> | 
DefaultGigaSpace.execute(Task<T> task)  | 
<T extends Serializable> | 
GigaSpace.execute(Task<T> task)
Executes a task on a specific space node. 
 | 
<T extends Serializable> | 
DefaultGigaSpace.execute(Task<T> task,
       AsyncFutureListener<T> listener)  | 
<T extends Serializable> | 
GigaSpace.execute(Task<T> task,
       AsyncFutureListener<T> listener)
Executes a task on a specific space node. 
 | 
<T extends Serializable> | 
DefaultGigaSpace.execute(Task<T> task,
       Object routing)  | 
<T extends Serializable> | 
GigaSpace.execute(Task<T> task,
       Object routing)
Executes a task on a specific space node. 
 | 
<T extends Serializable> | 
DefaultGigaSpace.execute(Task<T> task,
       Object routing,
       AsyncFutureListener<T> listener)  | 
<T extends Serializable> | 
GigaSpace.execute(Task<T> task,
       Object routing,
       AsyncFutureListener<T> listener)
Executes a task on a specific space node. 
 | 
<T> AsyncFuture<T> | 
DefaultGigaSpace.wrapFuture(AsyncFuture<T> future,
          Transaction tx)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> AsyncFuture<T> | 
DefaultGigaSpace.wrapFuture(AsyncFuture<T> future,
          Transaction tx)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> AsyncFuture<T> | 
DefaultTaskExecutorService.submit(Callable<T> task)  | 
AsyncFuture<?> | 
DefaultTaskExecutorService.submit(Runnable task)  | 
<T> AsyncFuture<T> | 
DefaultTaskExecutorService.submit(Runnable task,
      T result)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> AsyncFuture<T> | 
InternalGigaSpace.wrapFuture(AsyncFuture<T> future,
          Transaction tx)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> AsyncFuture<T> | 
InternalGigaSpace.wrapFuture(AsyncFuture<T> future,
          Transaction tx)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
InternalAsyncFuture<T>  | 
| Constructor and Description | 
|---|
InternalAsyncFuture(AsyncFuture<T> future,
                   GigaSpace gigaSpace)  | 
InternalAsyncFuture(AsyncFuture<T> future,
                   GigaSpace gigaSpace,
                   Transaction tx)  | 
| Modifier and Type | Method and Description | 
|---|---|
AsyncFuture | 
SingleReadAsyncOperationHandler.asyncReceive(Object template,
            GigaSpace gigaSpace,
            long receiveTimeout,
            AsyncFutureListener listener)
Performs a single take usign  
GigaSpace.asyncRead(Object). | 
AsyncFuture | 
ExclusiveReadAsyncOperationHandler.asyncReceive(Object template,
            GigaSpace gigaSpace,
            long receiveTimeout,
            AsyncFutureListener listener)
Performs a single take usign  
GigaSpace.asyncRead(Object) under
 exclusive read lock. | 
AsyncFuture | 
AsyncOperationHandler.asyncReceive(Object template,
            GigaSpace gigaSpace,
            long receiveTimeout,
            AsyncFutureListener listener)
Perform the async receive operation. 
 | 
AsyncFuture | 
SingleTakeAsyncOperationHandler.asyncReceive(Object template,
            GigaSpace gigaSpace,
            long receiveTimeout,
            AsyncFutureListener listener)
Performs a single take usign  
GigaSpace.asyncTake(Object). | 
Copyright © GigaSpaces.