Patent ID: 8037123
Filing Date: 2011-10-11
Classification: G06F

Abstract:
1. At a computer system, the computer system including a processor and system memory, the computer system also including a data pipeline comprising a sequential arrangement of a plurality of pipeline modules, an electronic message received at the data pipeline being sequentially processed by pipeline modules such that the output of at least one pipeline module is the input to the next sequential pipeline module, a method for extending the functionality of the data processing pipeline, the method comprising: an act of an agent engine that is external to the data pipeline detecting an occurrence of an event within the data pipeline; an act of mapping the detected event to a specified topic string representing an electronic messaging command; an act of matching the specified topic string to the topic string for a plurality of data processing agents previously stored at a specified known location at the computer system so as to determine that the plurality of data processing agents have registered for the detected event, the plurality of data processing agents being external to the data pipeline; an act of the processor loading each of the plurality of data processing agents into a secure zone such that execution of each data processing agent in the plurality of data processing agents is isolated from execution of all the other data processing agents in the plurality of data processing agents; for each of the plurality of data processing agents: the specified known location at the computer system storing data processing agents mapped to each of the following topic strings and Extended Simple Mail Transfer Protocol keywords and verbs: