Uses of Interface
com.gigaspaces.async.AsyncFutureListener

Packages that use AsyncFutureListener

com.gigaspaces.async	Provides GigaSpaces asynchronous operations related interfaces.
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.support
org.openspaces.events.asyncpolling.receive

Uses of AsyncFutureListener in com.gigaspaces.async

Methods in com.gigaspaces.async with parameters of type AsyncFutureListener

void	AsyncFuture.setListener(AsyncFutureListener<T> listener)

Uses of AsyncFutureListener in org.openspaces.core

Methods in org.openspaces.core that return AsyncFutureListener

<T> AsyncFutureListener<T>

DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener, Transaction tx)

Methods in org.openspaces.core with parameters of type AsyncFutureListener

ExecutorBuilder<T,R>	ExecutorBuilder.add(Task<T> task, AsyncFutureListener<T> listener) Adds a task to be executed similarly to GigaSpace.execute(org.openspaces.core.executor.Task).
AsyncFuture<AddTypeIndexesResult>	DefaultGigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index, AsyncFutureListener<AddTypeIndexesResult> listener)
AsyncFuture<AddTypeIndexesResult>	GigaSpaceTypeManager.asyncAddIndex(String typeName, SpaceIndex index, AsyncFutureListener<AddTypeIndexesResult> listener) Adds the specified index to the specified type.
AsyncFuture<AddTypeIndexesResult>	DefaultGigaSpaceTypeManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener)
AsyncFuture<AddTypeIndexesResult>	GigaSpaceTypeManager.asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) Adds the specified indexes to the specified type.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(ISpaceQuery<T> query, ChangeSet changeSet, long timeout, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(T template, ChangeSet changeSet, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(T template, ChangeSet changeSet, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<T> Future<ChangeResult<T>>	DefaultGigaSpace.asyncChange(T template, ChangeSet changeSet, long timeout, AsyncFutureListener<ChangeResult<T>> listener)
<T> Future<ChangeResult<T>>	GigaSpace.asyncChange(T template, ChangeSet changeSet, long timeout, AsyncFutureListener<ChangeResult<T>> listener) Changes existing objects in space in an asynchronous manner, returning immidiately with a future.
<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, 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, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(ISpaceQuery<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncRead(ISpaceQuery, long, ReadModifiers, AsyncFutureListener) instead.
<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, 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, 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, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncRead(T template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncRead(Object, long, ReadModifiers, AsyncFutureListener) instead.
<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, 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, 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, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(ISpaceQuery<T> template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncTake(ISpaceQuery, long, TakeModifiers, AsyncFutureListener) instead.
<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, 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, 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, int modifiers, AsyncFutureListener<T> listener)
<T> AsyncFuture<T>	GigaSpace.asyncTake(T template, long timeout, int modifiers, AsyncFutureListener<T> listener) Deprecated. since 9.0.1 - use GigaSpace.asyncTake(Object, long, TakeModifiers, AsyncFutureListener) instead.
<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> AsyncFuture<R>	DefaultGigaSpace.distExecute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
<T extends Serializable> AsyncFuture<T>	DefaultGigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener)
<T extends Serializable> AsyncFuture<T>	GigaSpace.execute(Task<T> task, AsyncFutureListener<T> listener) Executes a task on a specific space node.
<T extends Serializable> AsyncFuture<T>	DefaultGigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener)
<T extends Serializable> AsyncFuture<T>	GigaSpace.execute(Task<T> task, Object routing, AsyncFutureListener<T> listener) Executes a task on a specific space node.
<T> AsyncFutureListener<T>	DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener, Transaction tx)

Uses of AsyncFutureListener in org.openspaces.core.executor.support

Classes in org.openspaces.core.executor.support that implement AsyncFutureListener

class	WaitForAllListener<T> A listener that can be used to set on several execution and then wait for all the results (using WaitForAllListener.waitForResult().
class	WaitForAnyListener<T> A listener that can be used to set on several execution and then wait for any of the results (using WaitForAnyListener.waitForResult().

Constructors in org.openspaces.core.executor.support with parameters of type AsyncFutureListener

WaitForAllListener(int numberOfResults, AsyncFutureListener<T> listener)
Constructs a new listener with the number of executions this listener will be set on with an optional delegate listener.

WaitForAnyListener(int numberOfResults, AsyncFutureListener<T> listener)
Constructs a new listener with the number of executions this listener will be set on with an optional delegate listener.

Uses of AsyncFutureListener in org.openspaces.events.asyncpolling.receive

Methods in org.openspaces.events.asyncpolling.receive with parameters of type AsyncFutureListener

AsyncFuture	ExclusiveReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncRead(Object) under exclusive read lock.
AsyncFuture	SingleTakeAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncTake(Object).
AsyncFuture	SingleReadAsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Performs a single take usign GigaSpace.asyncRead(Object).
AsyncFuture	AsyncOperationHandler.asyncReceive(Object template, GigaSpace gigaSpace, long receiveTimeout, AsyncFutureListener listener) Perform the async receive operation.