An implementation of the
IPipelineFactory interface is used to obtain an instance of a pipeline derived from
Pipelines are re-used and as soon as a
MessagePipeline is obtained the internal state of the pipeline is cleared.
Although the pipeline factory may be replaced with your own implementation the
DefaultPipelineFactory implementation should suffice.
MessagePipeline GetPipeline<TPipeline>(IServiceBus bus) where TPipeline : MessagePipeline;
The method will return a new instance of the pipeline if one is not available; else it will return one from the pool of release instances.
void ReleasePipeline(MessagePipeline messagePipeline);
This method inform the factory that the pipeline execution is complete and may be released into the pool of available of instances.