Composing message processing pipelines

A computer storage device having stored computer-executable instructions which, when executed by one or more processors, implement a method for processing pipeline specifications, wherein the method comprises:

• an act of accessing a current pipeline specification for the application, the current pipeline specification specifying how to construct a message processing pipeline for the application;
• an act of accessing additional message processing requirements for the application;
• an act of identifying transforms that can be applied to the current pipeline specification to specify additional message processing functionality that satisfies the additional message processing requirements;
• and
• an act of applying the identified transforms to the current pipeline specification to create a transformed pipeline specification for the application, the transformed pipeline specification specifying how to construct a message processing pipeline for the application that satisfies the additional message processing requirements, including the additional message processing requirements.

A computer system, the computer system comprising:

• one or more processors;
• system memory;
• one or more computer storage media having stored thereon computer-executable instructions representing a pipeline transformation module and collection of available messaging pipeline components, each of the available messaging pipeline components providing differing message pipeline processing functionality, wherein the pipeline transformation module is configured to:
• receive a set of application requirements that a message processing pipeline is to satisfy;
• identify an arrangement of the available messaging pipeline components that can interact to satisfy the set of requirements;
• and
• transform a message processing pipeline specification, the transform specifying that the interaction between the arrangement of available messaging pipeline components is to be included within an intra-pipeline communication link between other pipeline components included in a message processing pipeline instantiated from the message processing pipeline specification.