org.mule.runtime.module.extension.internal.runtime.operation

Class InterceptingExecutionMediator

java.lang.Object

org.mule.runtime.module.extension.internal.runtime.operation.InterceptingExecutionMediator

All Implemented Interfaces:

ExecutionMediator

public final class InterceptingExecutionMediator
extends Object
implements ExecutionMediator

An ExecutionMediator for intercepting operations.

It works by wrapping another mediator which is expected to return an InterceptingCallback (IllegalStateException will be thrown otherwise). Once the callback has been obtained, it is placed as an ExecutionContextAdapter variable with key ExtensionProperties.INTERCEPTING_CALLBACK_PARAM and returns the value of InterceptingCallback.getResult().

This class is not responsible from actually invoking the intercepted chain nor invoking additional methods on the callback.

Since:

4.0

Constructor Summary

Constructors

Constructor and Description
InterceptingExecutionMediator(ExecutionMediator intercepted) Creates a new instance

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<Object>	execute(org.mule.runtime.extension.api.runtime.operation.OperationExecutor executor, ExecutionContextAdapter context) Coordinates the execution of the executor using the given context

Methods inherited from class java.lang.Object

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

Constructor Detail

InterceptingExecutionMediator

public InterceptingExecutionMediator(ExecutionMediator intercepted)

Creates a new instance

Parameters:

intercepted - a mediator which will actually execute the operation

Method Detail

execute

public org.reactivestreams.Publisher<Object> execute(org.mule.runtime.extension.api.runtime.operation.OperationExecutor executor,
                                                     ExecutionContextAdapter context)

Description copied from interface: ExecutionMediator

Coordinates the execution of the executor using the given context

Specified by:

execute in interface ExecutionMediator

Parameters:

executor - an OperationExecutor

context - an ExecutionContextAdapter

Returns:

a Mono with the operation's result