org.mule.api.processor

Interface DynamicPipelineBuilder

public interface DynamicPipelineBuilder

Updates a dynamic pipeline by ways of injecting message processor before and after the static chain. The injected message processors are executed before (pre) of after (post) the ones defined in the flow in the specified order. Also allows for resetting the dynamic chain.

Method Summary

Methods

Modifier and Type	Method and Description
DynamicPipelineBuilder	injectAfter(List<MessageProcessor> messageProcessors) Helper builder for injecting message processors to be executed after the ones specified in the flow.
DynamicPipelineBuilder	injectAfter(MessageProcessor... messageProcessors) Helper builder for injecting message processors to be executed after the ones specified in the flow.
DynamicPipelineBuilder	injectBefore(List<MessageProcessor> messageProcessors) Helper builder for injecting message processors to be executed before the ones specified in the flow.
DynamicPipelineBuilder	injectBefore(MessageProcessor... messageProcessors) Helper builder for injecting message processors to be executed before the ones specified in the flow.
String	reset() Removes and disposes all injected message processors.
String	resetAndUpdate() Injects the message processors added with injectBefore(org.mule.api.processor.MessageProcessor...) and injectAfter(org.mule.api.processor.MessageProcessor...) If none were added the effect is the same as calling reset()

Method Detail

injectBefore

DynamicPipelineBuilder injectBefore(MessageProcessor... messageProcessors)

Helper builder for injecting message processors to be executed before the ones specified in the flow. After adding all required message processors resetAndUpdate() must be called.

Parameters:

messageProcessors - message processors to be executed before the ones specified in the flow

Returns:

the pipeline injector builder instance

injectBefore

DynamicPipelineBuilder injectBefore(List<MessageProcessor> messageProcessors)

Helper builder for injecting message processors to be executed before the ones specified in the flow. After adding all required message processors resetAndUpdate() must be called.

Parameters:

messageProcessors - list of message processors to be executed before the ones specified in the flow

Returns:

the pipeline injector builder instance

injectAfter

DynamicPipelineBuilder injectAfter(MessageProcessor... messageProcessors)

Helper builder for injecting message processors to be executed after the ones specified in the flow. After adding all required message processors resetAndUpdate() must be called.

Parameters:

messageProcessors - message processors to be executed after the ones specified in the flow

Returns:

the pipeline injector builder instance

injectAfter

DynamicPipelineBuilder injectAfter(List<MessageProcessor> messageProcessors)

Helper builder for injecting message processors to be executed after the ones specified in the flow. After adding all required message processors resetAndUpdate() must be called.

Parameters:

messageProcessors - list of message processors to be executed after the ones specified in the flow

Returns:

the pipeline injector builder instance

resetAndUpdate

String resetAndUpdate()
                      throws MuleException

Injects the message processors added with injectBefore(org.mule.api.processor.MessageProcessor...) and injectAfter(org.mule.api.processor.MessageProcessor...) If none were added the effect is the same as calling reset()

Returns:

pipeline ID for future updates

Throws:

MuleException - if the update fails

reset

String reset()
             throws MuleException

Removes and disposes all injected message processors.

Returns:

pipeline ID for future updates

Throws:

MuleException - if the update fails