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 and Description
AsyncExtension()

Method Summary

Modifier and Type	Method and 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, 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, ISpaceQuery<T> query, ChangeSet changeSet, 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, ChangeModifiers modifiers)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, T template, ChangeSet changeSet, ChangeModifiers modifiers, long timeout, TimeUnit timeUnit)
static <T> CompletableFuture<ChangeResult<T>>	asyncChange(GigaSpace gigaSpace, T template, ChangeSet changeSet, 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 Detail

AsyncExtension

public AsyncExtension()

Method Detail

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)