×

Securely extending data processing pipeline functionality

  • US 7,627,636 B2
  • Filed: 10/27/2004
  • Issued: 12/01/2009
  • Est. Priority Date: 08/27/2004
  • Status: Active Grant
First Claim
Patent Images

1. A computer program product for use at a computer system, the computer system including a data pipeline comprising a sequential arrangement of a plurality of pipeline modules, an electronic message received at the data pipeline being sequential processed by pipeline modules such that the output of at least one pipeline module is the input to the next sequential pipeline module, the computer program product for implementing a method for invoking an agent runtime to customize the functionality of a data pipeline, the computer program product comprising computer-readable storage medium having stored thereon computer-executable instructions that, when executed by a processor, cause the computer system to perform the method, including the following:

  • receive electronic message related data at a pipeline module in the sequential arrangement of pipeline modules;

    detect the occurrence of an event at the pipeline module in response to processing the electronic message related data at the pipeline module;

    mapping the detected event to a specified topic string representing an electronic messaging command;

    scan configuration data for stored agents to attempt to identify any stored agents having topic strings corresponding to the specified topic string;

    indentify an agent having a topic string corresponding to the specified topic string, the agent having the corresponding topic string indicating that the agent is self-configured to hook into the detected event;

    loading the identified agent such that the identified agent can be executed to manipulate messaging data associated with the detected event in accordance with the configuration data for the identified agent, loading the identified agent including supplying appropriate values to an invoke API to invoke the identified agent, supplying appropriate values including supplying values for;

    an execution context field for storing an execution context value that identifies an execution context object for an agent runtime;

    an event topic field for storing an event topic value that represents a type of event that is to be processed by the agent runtime in the execution context object identified by the execution context value stored in the execution context field;

    a contexts field for storing a list of context values that represent a corresponding list of objects from a data processing pipeline that can be accessed from the execution context object identified by the execution context value stored in the execution context field;

    divert pipeline data related to the represented messaging command out of the data pipeline to the identified agent to extend the functionality of the data pipeline subsequent to loading the agent; and

    inject results from the identified agent back into the data pipeline for further processing.

View all claims
  • 2 Assignments
Timeline View
Assignment View
    ×
    ×