Modifier and Type | Method and Description |
---|---|
void |
SettableFuture.setListener(AsyncFutureListener<T> listener) |
void |
AsyncFuture.setListener(AsyncFutureListener<T> listener) |
Modifier and Type | Class and Description |
---|---|
class |
CompoundFuture<T,R>
a future implementation used to aggregate results from multiple Futures.
|
Modifier and Type | Method and Description |
---|---|
void |
CompoundFuture.setListener(AsyncFutureListener<R> listener) |
Modifier and Type | Class and Description |
---|---|
class |
SpaceIteratorBatchResultListener |
Modifier and Type | Method and Description |
---|---|
<T> Future<ChangeResult<T>> |
LocalCacheImplChangeAction.asyncChange(LocalCacheContainer spaceProxy,
ChangeProxyActionInfo actionInfo,
AsyncFutureListener listener) |
AsyncFuture |
LocalCacheImplAdminAction.execute(LocalCacheContainer spaceProxy,
SpaceTask task,
Object routing,
Transaction txn,
AsyncFutureListener listener) |
void |
LocalCacheImplAsyncOperationsFuture.setListener(AsyncFutureListener<T> listener) |
Modifier and Type | Method and Description |
---|---|
<T> Future<ChangeResult<T>> |
LocalViewImplChangeAction.asyncChange(LocalViewContainer spaceProxy,
ChangeProxyActionInfo actionInfo,
AsyncFutureListener listener) |
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) |
<T> Future<ChangeResult<T>> |
ISpaceProxy.asyncChange(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
AbstractSpaceProxy.asyncChange(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> 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 | Field and Description |
---|---|
AsyncFutureListener |
ReadTakeAsyncProxyActionInfo.listener |
Constructor and Description |
---|
ReadTakeAsyncProxyActionInfo(ISpaceProxy spaceProxy,
Object template,
Transaction txn,
long timeout,
int modifiers,
boolean isTake,
AsyncFutureListener<?> listener) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture<AddTypeIndexesResult> |
AbstractSpaceProxyActionManager.asyncAddIndexes(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener) |
<T> Future<ChangeResult<T>> |
AbstractSpaceProxyActionManager.asyncChange(Object template,
ChangeSet changeSet,
Transaction txn,
long timeout,
ChangeModifiers modifiers,
AsyncFutureListener<ChangeResult<T>> listener) |
<T> Future<ChangeResult<T>> |
SpaceProxyImplChangeAction.asyncChange(SpaceProxyImpl spaceProxy,
ChangeProxyActionInfo actionInfo,
AsyncFutureListener listener) |
abstract <T> Future<ChangeResult<T>> |
ChangeProxyAction.asyncChange(TSpaceProxy spaceProxy,
ChangeProxyActionInfo actionInfo,
AsyncFutureListener listener) |
AsyncFuture<?> |
AbstractSpaceProxyActionManager.asyncRead(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener<?> listener) |
AsyncFuture<?> |
AbstractSpaceProxyActionManager.asyncTake(Object template,
Transaction txn,
long timeout,
int modifiers,
AsyncFutureListener<?> listener) |
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 |
---|---|
<T extends SpaceOperationResult> |
SpaceProxyRouter.executeAsync(RemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener) |
Modifier and Type | Class and Description |
---|---|
class |
SpaceCopyReplicaRunnable
Retrieve space copy replica data, can have multiple instances of this class running concurrently
to retrieve the replica data
|
Modifier and Type | Method and Description |
---|---|
static void |
LeaseUtils.updateBatchAsync(IDirectSpaceProxy spaceProxy,
LeaseUpdateBatch batch,
AsyncFutureListener<Map<SpaceLease,Throwable>> listener) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteOperationFutureListener.setListener(AsyncFutureListener<Object> listener) |
Constructor and Description |
---|
RemoteOperationFutureListener(org.slf4j.Logger logger,
AsyncFutureListener<Object> listener) |
RemoteOperationFutureListener(org.slf4j.Logger logger,
AsyncFutureListener<Object> listener,
boolean getResultOnCompletion) |
Modifier and Type | Method and Description |
---|---|
<T extends RemoteOperationResult> |
RemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterRemoteOperationRouter.AsyncOperationExecutor<T extends RemoteOperationResult> |
Modifier and Type | Method and Description |
---|---|
<T extends RemoteOperationResult> |
ClusterRemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener) |
<T extends RemoteOperationResult> |
RemoteOperationsExecutorProxy.executeAsync(RemoteOperationRequest<T> request,
AsyncFutureListener<T> listener) |
Modifier and Type | Method and Description |
---|---|
<T extends RemoteOperationResult> |
EmbeddedRemoteOperationRouter.createFutureListener(RemoteOperationRequest<T> request,
AsyncFutureListener<Object> listener) |
Constructor and Description |
---|
BroadcastOperationFutureListener(RemoteOperationRequest<T> mainRequest,
AsyncFutureListener<Object> listener,
PartitionedClusterRemoteOperationRouter router,
boolean getResultOnCompletion) |
ScatterGatherOperationFutureListener(ScatterGatherRemoteOperationRequest<T> mainRequest,
AsyncFutureListener<Object> listener,
PartitionedClusterRemoteOperationRouter router,
boolean getResultOnCompletion) |
Modifier and Type | Method and Description |
---|---|
AsyncFutureListener<AddTypeIndexesResult> |
AddTypeIndexesRequestInfo.getListener() |
Modifier and Type | Method and Description |
---|---|
void |
AddTypeIndexesRequestInfo.setListener(AsyncFutureListener<AddTypeIndexesResult> listener) |
Constructor and Description |
---|
AddTypeIndexesRequestInfo(String typeName,
SpaceIndex[] indexes,
AsyncFutureListener<AddTypeIndexesResult> listener) |
Modifier and Type | Method and Description |
---|---|
static AsyncFutureListener |
FutureContext.getFutureListener() |
AsyncFutureListener |
FutureContext.FutureParams.getListener() |
Modifier and Type | Method and Description |
---|---|
static void |
FutureContext.setFutureListener(AsyncFutureListener listener) |
void |
LRMIFuture.setListener(AsyncFutureListener<T> listener) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncFutureListener<T> |
DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
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> |
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) |
<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,
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,
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,
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,
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) |
<T extends Serializable,R> |
DefaultGigaSpace.execute(DistributedTask<T,R> task,
AsyncFutureListener<R> listener) |
<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,
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> AsyncFutureListener<T> |
DefaultGigaSpace.wrapListener(AsyncFutureListener<T> listener,
Transaction tx) |
Modifier and Type | Class and Description |
---|---|
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() . |
Constructor and Description |
---|
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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TransactionalAsyncFutureListener<T>
Extends the future listener, resulting in calling the
TransactionalAsyncFutureListener.onTransactionalResult(com.gigaspaces.async.AsyncResult,
org.springframework.transaction.TransactionStatus) after the onResult(com.gigaspaces.async.AsyncResult) . |
Modifier and Type | Class and Description |
---|---|
class |
InternalAsyncFutureListener<T> |
Modifier and Type | Method and Description |
---|---|
static <T> AsyncFutureListener<T> |
InternalAsyncFutureListener.wrapIfNeeded(AsyncFutureListener<T> listener,
GigaSpace gigaSpace) |
Modifier and Type | Method and Description |
---|---|
void |
InternalAsyncFuture.setListener(AsyncFutureListener<T> listener) |
static <T> AsyncFutureListener<T> |
InternalAsyncFutureListener.wrapIfNeeded(AsyncFutureListener<T> listener,
GigaSpace gigaSpace) |
Constructor and Description |
---|
InternalAsyncFutureListener(GigaSpace gigaSpace,
AsyncFutureListener<T> listener) |
InternalAsyncFutureListener(GigaSpace gigaSpace,
AsyncFutureListener<T> listener,
org.springframework.transaction.TransactionStatus txStatus,
org.springframework.transaction.PlatformTransactionManager transactionManager,
JiniTransactionHolder holder) |
Modifier and Type | Method and Description |
---|---|
AsyncFuture |
AsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Perform the async receive operation.
|
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 |
SingleTakeAsyncOperationHandler.asyncReceive(Object template,
GigaSpace gigaSpace,
long receiveTimeout,
AsyncFutureListener listener)
Performs a single take usign
GigaSpace.asyncTake(Object) . |
Copyright © GigaSpaces.