Interface AsyncInterceptor

All Known Implementing Classes:

BaseAsyncInterceptor, BaseCustomAsyncInterceptor, DDAsyncInterceptor, PartitionHandlingInterceptor

@Experimental
public interface AsyncInterceptor

Interface for sequential interceptors.

Since:

9.0

Author:

Dan Berindei

Method Summary

Modifier and Type	Method	Description
void	setNextInterceptor(AsyncInterceptor interceptorStage)	Sets up the interceptor.
Object	visitCommand(InvocationContext ctx, VisitableCommand command)	Perform some work for a command invocation.

Method Details

visitCommand

Object visitCommand(InvocationContext ctx,
 VisitableCommand command)
             throws Throwable

Perform some work for a command invocation. The interceptor is responsible for invoking the next interceptor in the chain, using BaseAsyncInterceptor.invokeNext(InvocationContext, VisitableCommand) or the other methods in BaseAsyncInterceptor.

Returns:

Either a regular value, or an InvocationStage created by the BaseAsyncInterceptor methods.

Throws:

Throwable

setNextInterceptor

void setNextInterceptor(AsyncInterceptor interceptorStage)

Sets up the interceptor. Do not call explicitly.