Correlating event streams from independent processes in a complex business system using metadata associated with the transport interconnections

摘要

A system and computer program product for correlating business events in a complex business system. A flow diagram containing a collection of nodes (representing processes) and links (representing the transport connections) between these nodes is generated. An instance of an event stream from a node that is to be connected to an instance of an event stream from a neighboring node is identified when a node transports a transaction across a link. The metadata associated with the utilized link that was used to transport the transaction between the nodes is obtained. The instances of the event streams are then correlated using the obtained metadata. Further, each instance of the event streams is assigned an identification. In this manner, business events are correlated without the requirement of users providing a common key as well as without the requirement of monitoring each user of the system throughout the entire transaction.

主权项

1. A computer program product embodied in a computer readable storage medium for correlating business events in a business system, the computer program product comprising the programming instructions for:
generating a flow diagram comprising a plurality of nodes and links interconnected between said plurality of nodes, wherein each of said plurality of nodes represents a process involved in a coordinated transaction; monitoring event streams generated from said plurality of nodes; identifying an instance of a first event stream from a first node that is to be connected to an instance of a second event stream from a second node, wherein said second node is a neighboring node of said first node; obtaining metadata contained within one of said first event stream and said second event stream associated with a link utilized to transport said coordinated transaction between said first node and said second node; and correlating said instances of said first and said second event streams with said obtained metadata; and assigning each instance of said first and said second event streams with an identification.