org.mule.api.construct

Interface Pipeline

All Superinterfaces:

FlowConstruct, LifecycleStateEnabled, MessageProcessorContainer, MessageProcessorPathResolver, NamedObject, ProcessingDescriptor

All Known Implementing Classes:

AbstractConfigurationPattern, AbstractPipeline, Bridge, Flow, HttpProxy, SimpleService, Validator, WSProxy

public interface Pipeline
extends FlowConstruct, MessageProcessorContainer, ProcessingDescriptor, MessageProcessorPathResolver

A pipeline has an ordered list of MessageProcessor's that are invoked in order to processor new messages received from it's MessageSource

Method Summary

Methods

Modifier and Type	Method and Description
List<MessageProcessor>	getMessageProcessors()
MessageSource	getMessageSource()
ProcessingStrategy	getProcessingStrategy()
void	setMessageProcessors(List<MessageProcessor> messageProcessors)
void	setMessageSource(MessageSource messageSource)
void	setProcessingStrategy(ProcessingStrategy processingStrategy)

Methods inherited from interface org.mule.api.construct.FlowConstruct

getExceptionListener, getMessageInfoMapping, getMuleContext, getStatistics

Methods inherited from interface org.mule.api.NamedObject

getName

Methods inherited from interface org.mule.api.lifecycle.LifecycleStateEnabled

getLifecycleState

Methods inherited from interface org.mule.api.processor.MessageProcessorContainer

addMessageProcessorPathElements

Methods inherited from interface org.mule.api.processor.ProcessingDescriptor

isSynchronous

Methods inherited from interface org.mule.api.construct.MessageProcessorPathResolver

getProcessorPath

Method Detail

setMessageSource

void setMessageSource(MessageSource messageSource)

getMessageSource

MessageSource getMessageSource()

setMessageProcessors

void setMessageProcessors(List<MessageProcessor> messageProcessors)

getMessageProcessors

List<MessageProcessor> getMessageProcessors()

setProcessingStrategy

void setProcessingStrategy(ProcessingStrategy processingStrategy)

getProcessingStrategy

ProcessingStrategy getProcessingStrategy()