Composing message processing pipelines

摘要

The present invention extends to methods, systems, and computer program products for composing message processing pipelines. Embodiments utilize intra-pipeline communication links to physically and/or temporally decouple pipeline stages, configure branching message flows, and bridge protocols. The use of intra-pipeline communication links permits composition of a message processing pipeline without having to alter the pipeline components or application. Each communication link is itself an application with incoming and outgoing message processing pipelines that bridge messages across time and/or space and application logic for satisfying message processing requirements.

主权项

1. At a computer system including one or more hardware processors and system memory, a method for processing pipeline specifications, the method comprising:
an act of the computer system accessing a first pipeline specification for the application that specifies at least a first pipeline component to be included in a message processing pipeline which is dependent on a first code library at a first computer system, the first pipeline specification specifying how to construct the message processing pipeline for the application; an act of the computer system accessing a second pipeline specification for the application that specifies at least a second pipeline component to be included in the message processing pipeline which is dependent on a second code library at a second computer system; an act of the computer system accessing additional message processing requirements for the application; an act of the computer system identifying transforms that can be applied to the first pipeline specification to specify additional message processing functionality that satisfies the additional message processing requirements; an act of the computer system applying the identified transforms to the first 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, by specifying at least one intra-pipeline communication link having an arrangement of message processing components that satisfy the additional message processing requirements; an act of determining that the first library is available at the first computer system; and an act of determining that the second library is available at the second computer system that is different than the first computer system.