org.openspaces.core.transaction.internal

Class InternalAsyncFutureListener<T>

java.lang.Object

org.openspaces.core.transaction.internal.InternalAsyncFutureListener<T>

All Implemented Interfaces:

AsyncFutureListener<T>

public class InternalAsyncFutureListener<T>
extends Object
implements AsyncFutureListener<T>

Author:

kimchy

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	onResult(AsyncResult<T> asyncResult) A callback when a result of an async invocation arrives.
static <T> AsyncFutureListener<T>	wrapIfNeeded(AsyncFutureListener<T> listener, GigaSpace gigaSpace)

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalAsyncFutureListener

public InternalAsyncFutureListener(GigaSpace gigaSpace,
                                   AsyncFutureListener<T> listener)

InternalAsyncFutureListener

public InternalAsyncFutureListener(GigaSpace gigaSpace,
                                   AsyncFutureListener<T> listener,
                                   org.springframework.transaction.TransactionStatus txStatus,
                                   org.springframework.transaction.PlatformTransactionManager transactionManager,
                                   JiniTransactionHolder holder)

Method Detail

wrapIfNeeded

public static <T> AsyncFutureListener<T> wrapIfNeeded(AsyncFutureListener<T> listener,
                                                      GigaSpace gigaSpace)

onResult

public void onResult(AsyncResult<T> asyncResult)

Description copied from interface: AsyncFutureListener

A callback when a result of an async invocation arrives.

Specified by:

onResult in interface AsyncFutureListener<T>