Package org.openspaces.extensions

Class AsyncExtension

java.lang.Object

org.openspaces.extensions.AsyncExtension

public class AsyncExtension
extends Object

Since:

10.1

Author:

Barak Bar Orion

Constructor Summary

Constructors

Constructor	Description
AsyncExtension()

Method Summary

Modifier and Type	Method	Description
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, ISpaceQuery<T> query, ChangeSet changeSet)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, ISpaceQuery<T> query, ChangeSet changeSet, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, ISpaceQuery<T> query, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, T template, ChangeSet changeSet)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, T template, ChangeSet changeSet, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, T template, ChangeSet changeSet, ChangeModifiers modifiers)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<T>	asyncRead(GigaSpace gigaSpace, ISpaceQuery<T> template)
static <T> CompletableFuture<T>	asyncRead(GigaSpace gigaSpace, ISpaceQuery<T> template, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<T>	asyncRead(GigaSpace gigaSpace, ISpaceQuery<T> template, long timeout, TimeUnit timeUnit, ReadModifiers modifiers)
static <T> CompletableFuture<T>	asyncRead(GigaSpace gigaSpace, T template)
static <T> CompletableFuture<T>	asyncRead(GigaSpace gigaSpace, T template, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<T>	asyncRead(GigaSpace gigaSpace, T template, long timeout, TimeUnit timeUnit, ReadModifiers modifiers)
static <T> CompletableFuture<T>	asyncTake(GigaSpace gigaSpace, ISpaceQuery<T> template)
static <T> CompletableFuture<T>	asyncTake(GigaSpace gigaSpace, ISpaceQuery<T> template, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<T>	asyncTake(GigaSpace gigaSpace, ISpaceQuery<T> template, long timeout, TimeUnit timeUnit, TakeModifiers modifiers)
static <T> CompletableFuture<T>	asyncTake(GigaSpace gigaSpace, T template)
static <T> CompletableFuture<T>	asyncTake(GigaSpace gigaSpace, T template, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<T>	asyncTake(GigaSpace gigaSpace, T template, long timeout, TimeUnit timeUnit, TakeModifiers modifiers)
static <T extends Serializable, R> CompletableFuture<R>	execute(GigaSpace gigaSpace, DistributedTask<T,R> task)
static <T extends Serializable> CompletableFuture<T>	execute(GigaSpace gigaSpace, Task<T> task)
static <T extends Serializable> CompletableFuture<T>	execute(GigaSpace gigaSpace, Task<T> task, Object routing)
static <T extends Serializable> CompletableFuture<T>	execute(GigaSpace gigaSpace, Task<T> task, Object... routing)

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncExtension

public AsyncExtension()

Method Details

asyncRead

public static <T> CompletableFuture<T> asyncRead(GigaSpace gigaSpace,
 T template)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncRead

public static <T> CompletableFuture<T> asyncRead(GigaSpace gigaSpace,
 T template,
 long timeout,
 TimeUnit timeUnit)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncRead

public static <T> CompletableFuture<T> asyncRead(GigaSpace gigaSpace,
 T template,
 long timeout,
 TimeUnit timeUnit,
 ReadModifiers modifiers)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncRead

public static <T> CompletableFuture<T> asyncRead(GigaSpace gigaSpace,
 ISpaceQuery<T> template)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncRead

public static <T> CompletableFuture<T> asyncRead(GigaSpace gigaSpace,
 ISpaceQuery<T> template,
 long timeout,
 TimeUnit timeUnit)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncRead

public static <T> CompletableFuture<T> asyncRead(GigaSpace gigaSpace,
 ISpaceQuery<T> template,
 long timeout,
 TimeUnit timeUnit,
 ReadModifiers modifiers)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncTake

public static <T> CompletableFuture<T> asyncTake(GigaSpace gigaSpace,
 T template)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncTake

public static <T> CompletableFuture<T> asyncTake(GigaSpace gigaSpace,
 T template,
 long timeout,
 TimeUnit timeUnit)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncTake

public static <T> CompletableFuture<T> asyncTake(GigaSpace gigaSpace,
 T template,
 long timeout,
 TimeUnit timeUnit,
 TakeModifiers modifiers)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncTake

public static <T> CompletableFuture<T> asyncTake(GigaSpace gigaSpace,
 ISpaceQuery<T> template)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncTake

public static <T> CompletableFuture<T> asyncTake(GigaSpace gigaSpace,
 ISpaceQuery<T> template,
 long timeout,
 TimeUnit timeUnit)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

asyncTake

public static <T> CompletableFuture<T> asyncTake(GigaSpace gigaSpace,
 ISpaceQuery<T> template,
 long timeout,
 TimeUnit timeUnit,
 TakeModifiers modifiers)
                                          throws org.springframework.dao.DataAccessException

Throws:

org.springframework.dao.DataAccessException

execute

public static <T extends Serializable>
CompletableFuture<T> execute(GigaSpace gigaSpace,
 Task<T> task)

execute

public static <T extends Serializable>
CompletableFuture<T> execute(GigaSpace gigaSpace,
 Task<T> task,
 Object routing)

execute

public static <T extends Serializable>
CompletableFuture<T> execute(GigaSpace gigaSpace,
 Task<T> task,
 Object... routing)

execute

public static <T extends Serializable,
R>
CompletableFuture<R> execute(GigaSpace gigaSpace,
 DistributedTask<T,R> task)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 ISpaceQuery<T> query,
 ChangeSet changeSet)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 ISpaceQuery<T> query,
 ChangeSet changeSet,
 long timeout,
 TimeUnit timeUnit)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 ISpaceQuery<T> query,
 ChangeSet changeSet,
 ChangeModifiers modifiers)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 ISpaceQuery<T> query,
 ChangeSet changeSet,
 ChangeModifiers modifiers,
 long timeout,
 TimeUnit timeUnit)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 T template,
 ChangeSet changeSet)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 T template,
 ChangeSet changeSet,
 long timeout,
 TimeUnit timeUnit)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 T template,
 ChangeSet changeSet,
 ChangeModifiers modifiers)

asyncChange

public static <T>
CompletableFuture<ChangeResult<T>> asyncChange(GigaSpace gigaSpace,
 T template,
 ChangeSet changeSet,
 ChangeModifiers modifiers,
 long timeout,
 TimeUnit timeUnit)