Event processing networks

• US 9,977,702 B2
• Filed: 11/23/2009
• Issued: 05/22/2018
• Est. Priority Date: 11/23/2009
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Iyer, Sreekanth R., Jayaseelan, Gowdhaman, Joseph, Jojo
• Primary Examiner(s): Sough, S
• Assistant Examiner(s): JORDAN, KIMBERLY L
• Application Number:
  US12/623,673
• Publication Number:
  US 20110126201A1
• Time in Patent Office: 3,102 Days
• Field of Search: 719318
• CPC Class Codes: G06F 2209/544 Remote
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A hybrid event processing network (EPN) having at least one event processing agent (EPA) consists of a first set of EPAs defined declaratively and a second set of EPAs defined dynamically at runtime via an interface. Deploying the hybrid EPN includes loading the hybrid EPN, constructing an EPN structure, and creating indexes of nodes of the EPN structure. Deploying the hybrid EPN further includes representing an event in a hybrid EPN, and, in response to the event occurrence at an event source, receiving a notification from the hybrid EPN based on the event, and publishing the notification in an event channel. Embodiments of the invention includes propagating the event received within the hybrid EPN, determining a subsequent EPA associated with the event within the hybrid EPN, and propagating the event to the subsequent EPA in the hybrid EPN until the last element of the hybrid EPN is reached.

Claims

1. A computer-implemented method within an event processing network (EPN) including a plurality of event processing agents (EPAs), comprising:

adding, to the EPN, a first EPA of a statically-configured type EPA that is not subject to being reconfigured at EPN runtime;

adding, to the EPN, a second EPA of a dynamically-configurable type EPA that is subject to being reconfigured at EPN runtime;

starting EPN runtime;

dynamically configuring, subsequent to starting EPN runtime, the second EPA;

receiving, subsequent to starting EPN runtime, an event data set including information indicative of an event to be processed by the EPN; and

processing the event by;

processing at least a portion of the event data set by the first EPA, and

processing at least a portion of the event data set by the second EPA.

2. The method of claim 1, wherein

the dynamic configuration of the second EPA is based, at least in part, upon characteristic(s) of the event.

3. The method of claim 1, wherein

an event router is configured to create an index and an EPN structure of the EPN.

4. The method of claim 1, further comprising

defining an event processing context including a pointer to an EPA of the EPN.

5. The method of claim 1, further comprising

defining an event processing agent interface for an event processing agent of the EPN.

6. The method of claim 5, wherein

the event processing agent interface is configured to modify an event flow of the EPN.

7. The method of claim 1, wherein

an EPA defines logic by which the event is to be processed.

8. A computer hardware system associated with an event processing network (EPN) including a plurality of event processing agents (EPAs), comprising:

a hardware processor configured to initiate the following operations;

adding, to the EPN, a first EPA of a statically-configured type EPA that is not subject to being reconfigured at EPN runtime;

adding, to the EPN, a second EPA of a dynamically-configurable type EPA that is subject to being reconfigured at EPN runtime;

starting EPN runtime;

dynamically configuring, subsequent to starting EPN runtime, the second EPA;

receiving, subsequent to starting EPN runtime, an event data set including information indicative of an event to be processed by the EPN; and

processing the event by;

processing at least a portion of the event data set by the first EPA, and

processing at least a portion of the event data set by the second EPA.

9. The system of claim 8, wherein

the dynamic configuration of the second EPA is based, at least in part, upon characteristic(s) of the event.

10. The system of claim 8, wherein

an event router is configured to create an index and an EPN structure of the EPN.

11. The system of claim 8, wherein the hardware processor is further configured to initiate the following operation:

defining an event processing context including a pointer to an EPA of the EPN.

12. The system of claim 8, wherein the hardware processor is further configured to initiate the following operation:

defining an event processing agent interface for an event processing agent of the EPN.

13. The method of claim 12, wherein

the event processing agent interface is configured to modify an event flow of the EPN.

14. The method of claim 8, wherein

an EPA defines logic by which the event is to be processed.

15. A computer program product, comprising:

a hardware storage device having stored therein machine-readable instructions,

the machine-readable instructions, which when executed by a computer hardware system associated with an event processing network (EPN) including a plurality of event processing agents (EPAs), causes the computer hardware system to perform;

adding, to the EPN, a first EPA of a statically-configured type EPA that is not subject to being reconfigured at EPN runtime;

adding, to the EPN, a second EPA of a dynamically-configurable type EPA that is subject to being reconfigured at EPN runtime;

starting EPN runtime;

dynamically configuring, subsequent to starting EPN runtime, the second EPA;

receiving, subsequent to starting EPN runtime, an event data set including information indicative of an event to be processed by the EPN; and

processing the event by;

processing at least a portion of the event data set by the first EPA, and

processing at least a portion of the event data set by the second EPA.

16. The computer program product of claim 15, wherein

the dynamic configuration of the second EPA is based, at least in part, upon characteristic(s) of the event.

17. The computer program product of claim 15, wherein

an event router is configured to create an index and an EPN structure of the EPN.

18. The computer program product of claim 15, wherein the machine-readable instructions further cause the computer hardware system to perform:

defining an event processing context including a pointer to an EPA of the EPN.

19. The computer program product of claim 15, wherein the machine-readable instructions further cause the computer hardware system to perform:

defining an event processing agent interface for an event processing agent of the EPN, wherein

the event processing agent interface is configured to modify an event flow of the EPN.

20. The computer program product of claim 15, wherein

an EPA defines logic by which the event is to be processed.