Event processing

• US 8,234,329 B2
• Filed: 11/23/2009
• Issued: 07/31/2012
• Est. Priority Date: 11/23/2009
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Iyer, Sreekanth R., Jayaseelan, Gowdhaman, Joseph, Jojo
• Primary Examiner(s): Nguyen, Quang N.
• Application Number:
  US12/623,595
• Publication Number:
  US 20110125825A1
• Time in Patent Office: 981 Days
• Field of Search: 709/223, 709/226, 709/231, 709/239
• US Class Current: 709/202
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A method, a system and a computer program for parallel event processing in an event processing network (EPN) are disclosed. The EPN has at least one event processing agent (EPA). The method includes assigning an execution mode for the at least one EPA, the execution mode including a concurrent mode and a sequential mode. The execution mode for the at least one EPA is stored in the EPN metadata. The method also includes loading and initializing the EPN. The method further includes routing the event in the EPN and, when an EPA is encountered, depending on the execution mode of the encountered EPA, further processing of the event. Also disclosed are a system and a computer program for parallel event processing in an event processing network (EPN).

Claims

1. A method for processing an event in an event processing network, the method comprising:

assigning an execution mode for at least one event processing agent (EPA) in an event processing network (EPN), the execution mode includes a concurrent mode and a sequential mode;

storing the execution mode for the at least one EPA in EPN metadata;

receiving an event, in response to an event occurrence at an event source, wherein the EPN includes the event source;

loading the EPN, wherein loading the EPN comprises creating a structure representing the EPN using the EPN metadata;

initializing the at least one EPA in the EPN;

routing the event in the EPN until encountering the EPA;

identifying an input event, wherein the input event corresponds to the encountered EPA;

determining the execution mode of the encountered EPA;

upon the execution mode determined to be in the concurrent mode, creating a replica of the input event;

identifying each child EPA of the encountered EPA;

allocating the replica of the input event to each child EPA of the encountered EPA;

creating a change summary corresponding to each child EPA, wherein the change summary is associated with the input event;

modifying the change summary corresponding to each child EPA in response to a modification performed by each child EPA on the replica of the input event; and

synchronizing the change summaries.

2. The method of claim 1, wherein synchronizing further comprises:

comparing the change summaries; and

merging the modifications performed by each child EPA on the replica of the input event.

3. The method of claim 2, further comprising:

identifying if there is a conflict in the modifications between at least two of the change summaries;

upon identification of a conflict, resolving the conflict; and

generating a modified input event using the synchronized change summary of each child EPA of the encountered EPA.

4. The method of claim 3, further comprising:

propagating the modified input event in the EPN.

5. A system for processing an event in an event processing network, the system comprising:

a processor configured to;

assign an execution mode for at least one event processing agent (EPA) in an event processing network (EPN), wherein the execution mode includes a concurrent mode and a sequential mode;

store the execution mode for the at least one EPA in EPN metadata;

receive an event, in response to an event occurrence at an event source, wherein the EPN includes the event source;

load the EPN, wherein loading the EPN comprises creating a structure representing the EPN using the EPN metadata;

initialize the at least one EPA in the EPN;

route the event in the EPN until encountering the EPA;

identify an input event, wherein the input event corresponds to the encountered EPA;

determine the execution mode of the encountered EPA;

upon the execution mode determined to be in the concurrent mode;

create a replica of the input event;

identify each child EPA of the encountered EPA;

allocate the replica of the input event to each child EPA of the encountered EPA;

create a change summary corresponding to each child EPA, wherein the change summary is associated with the input event;

modify the change summary corresponding to each child EPA in response to a modification performed by each child EPA on the replica of the input event;

synchronize the change summaries;

compare the change summaries;

merge the modifications performed by each child EPA on the replica of the input event;

identify if there is a conflict in the modifications between at least two of the change summaries;

upon identification of said conflict, resolve the conflict;

generate a modified input event using the synchronized change summary of each child EPA of the encountered EPA; and

propagate the modified input event in the EPN.

6. A storage device tangibly embodying a program of machine-readable instructions executable by a digital processing apparatus to carry out a method of processing an event in an event processing network, the storage medium configured to:

assign an execution mode for at least one event processing agent (EPA) in an event processing network (EPN), wherein the execution mode includes a concurrent mode and a sequential mode;

store the execution mode for the at least one EPA in EPN metadata;

receive an event, in response to an event occurrence, at an event source, wherein the EPN includes the event source;

load the EPN, wherein loading the EPN comprises creating a structure representing the EPN using the EPN metadata;

initialize the at least one EPA in the EPN;

route the event in the EPN until encountering the EPA;

identify an input event, wherein the input event corresponds to the encountered EPA;

determine the execution mode of the encountered EPA;

upon the execution mode determined to be in the concurrent mode, create a replica of the input event;

identify each child EPA of the encountered EPA;

allocate the replica of the input event to each of the child EPAs of the encountered EPA;

create a change summary corresponding to each of the child EPAs, wherein the change summary is associated with the input event;

modify the change summary in response to a modification performed by each of the child EPAs on the replica of the input event;

synchronize the change summaries corresponding to each of the child EPAs of the encountered EPA;

compare the change summary of each of the child EPAs;

merge the modifications performed by each of the child EPAs on the replica of the input event;

resolve a conflict in the modifications, if the conflict is identified between at least two of the change summaries;

generate a modified input event using the synchronized change summaries of each of the child EPAs of the encountered EPA; and

propate the modified input event in the EPN.