| Package | Description |
|---|---|
| org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
| org.infinispan.interceptors.impl |
Basic interceptors
|
| org.infinispan.interceptors.locking |
Interceptors dealing with locking.
|
| org.infinispan.util.concurrent.locks |
Lock and synchronization related classes, tools and utilities.
|
| org.infinispan.xsite |
| Modifier and Type | Class and Description |
|---|---|
class |
ExceptionSyncInvocationStage
A sync
InvocationStage for Throwable. |
class |
SyncInvocationStage |
| Modifier and Type | Method and Description |
|---|---|
<C extends VisitableCommand> |
InvocationStage.andExceptionallyMakeStage(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function)
After the current stage completes exceptionally, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.andExceptionallyMakeStage(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function) |
<C extends VisitableCommand> |
InvocationStage.andFinallyMakeStage(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action)
After the current stage completes, invoke
action. |
<C extends VisitableCommand> |
SyncInvocationStage.andFinallyMakeStage(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action) |
<C extends VisitableCommand> |
InvocationStage.andHandleMakeStage(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function)
After the current stage completes, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.andHandleMakeStage(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function) |
static InvocationStage |
BaseAsyncInterceptor.asyncValue(CompletionStage<?> valueFuture)
Suspend the invocation until
valueFuture completes, then return its result without running
the remaining interceptors. |
static InvocationStage |
InvocationStage.completedNullStage() |
static InvocationStage |
BaseAsyncInterceptor.makeStage(Object rv)
Encode the result of an
BaseAsyncInterceptor.invokeNext(InvocationContext, VisitableCommand) in an InvocationStage. |
static InvocationStage |
InvocationStage.makeStage(Object maybeStage)
If
maybeStage is not an InvocationStage, wrap it, otherwise cast it to an InvocationStage. |
<C extends VisitableCommand> |
InvocationStage.thenAcceptMakeStage(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action)
After the current stage completes successfully, invoke
action. |
<C extends VisitableCommand> |
SyncInvocationStage.thenAcceptMakeStage(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action) |
<C extends VisitableCommand> |
InvocationStage.thenApplyMakeStage(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function)
After the current stage completes successfully, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.thenApplyMakeStage(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function)
After the current stage completes successfully, invoke
function and return its result. |
| Modifier and Type | Method and Description |
|---|---|
Object |
BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx,
VisitableCommand command,
InvocationStage invocationStage)
Suspend the invocation until
invocationStage completes, then if successful invoke the next interceptor. |
| Modifier and Type | Class and Description |
|---|---|
class |
QueueAsyncInvocationStage
Invocation stage representing a computation that may or may not be done yet.
|
class |
SimpleAsyncInvocationStage
Invocation stage representing a computation that may or may not be done yet.
|
| Modifier and Type | Method and Description |
|---|---|
protected InvocationStage |
CacheWriterInterceptor.commitCommand(TxInvocationContext<AbstractCacheTransaction> ctx) |
protected InvocationStage |
CacheWriterInterceptor.store(TxInvocationContext<AbstractCacheTransaction> ctx) |
| Modifier and Type | Method and Description |
|---|---|
protected InvocationStage |
AbstractLockingInterceptor.lockAndRecord(InvocationContext context,
VisitableCommand command,
Object key,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
InvocationStage |
LockPromise.toInvocationStage() |
InvocationStage |
PendingLockPromise.toInvocationStage()
If successful,
PendingLockPromise.getRemainingTimeout() will return the remaining timeout, in millis. |
InvocationStage |
ExtendedLockPromise.toInvocationStage(Supplier<TimeoutException> timeoutSupplier) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.