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

Class ImmutableProcessorChainExecutor

java.lang.Object

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

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.extension.api.runtime.route.Chain

public class ImmutableProcessorChainExecutor
extends Object
implements org.mule.runtime.extension.api.runtime.route.Chain, org.mule.runtime.api.lifecycle.Initialisable

An implementation of Chain that wraps a Processor and allows to execute it

Since:

4.0

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Initialisable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
ImmutableProcessorChainExecutor(InternalEvent event, MessageProcessorChain chain) Creates a new immutable instance

Method Summary

Modifier and Type	Method and Description
void	initialise()
void	process(Consumer<org.mule.runtime.extension.api.runtime.operation.Result> onSuccess, BiConsumer<Throwable,org.mule.runtime.extension.api.runtime.operation.Result> onError)
void	process(Object payload, Object attributes, Consumer<org.mule.runtime.extension.api.runtime.operation.Result> onSuccess, BiConsumer<Throwable,org.mule.runtime.extension.api.runtime.operation.Result> onError)
void	process(org.mule.runtime.extension.api.runtime.operation.Result result, Consumer<org.mule.runtime.extension.api.runtime.operation.Result> onSuccess, BiConsumer<Throwable,org.mule.runtime.extension.api.runtime.operation.Result> onError)

Methods inherited from class java.lang.Object

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

Constructor Detail

ImmutableProcessorChainExecutor

public ImmutableProcessorChainExecutor(InternalEvent event,
                                       MessageProcessorChain chain)

Creates a new immutable instance

Parameters:

event - the original InternalEvent for the execution of the given chain

chain - a Processor chain to be executed

Method Detail

process

public void process(Consumer<org.mule.runtime.extension.api.runtime.operation.Result> onSuccess,
                    BiConsumer<Throwable,org.mule.runtime.extension.api.runtime.operation.Result> onError)

Specified by:

process in interface org.mule.runtime.extension.api.runtime.route.Chain

process

public void process(Object payload,
                    Object attributes,
                    Consumer<org.mule.runtime.extension.api.runtime.operation.Result> onSuccess,
                    BiConsumer<Throwable,org.mule.runtime.extension.api.runtime.operation.Result> onError)

Specified by:

process in interface org.mule.runtime.extension.api.runtime.route.Chain

process

public void process(org.mule.runtime.extension.api.runtime.operation.Result result,
                    Consumer<org.mule.runtime.extension.api.runtime.operation.Result> onSuccess,
                    BiConsumer<Throwable,org.mule.runtime.extension.api.runtime.operation.Result> onError)

Specified by:

process in interface org.mule.runtime.extension.api.runtime.route.Chain

initialise

public void initialise()
                throws org.mule.runtime.api.lifecycle.InitialisationException

Specified by:

initialise in interface org.mule.runtime.api.lifecycle.Initialisable

Throws:

org.mule.runtime.api.lifecycle.InitialisationException