Complex event processing system having multiple redundant event processing engines
First Claim
1. A system for complex event processing comprising:
- a sender module for receiving an input event and for generating a serialized message sequence from the input event;
a plurality of deterministic event processing engines for processing the serialized message sequence and generating a plurality of redundant ordered sequences;
a merger module for receiving the plurality of redundant ordered sequences and for generating an output result for transmission; and
wherein at least one of the sender module, deterministic event processing engines and merger module comprises at least one hardware component.
2 Assignments
0 Petitions
Accused Products
Abstract
A system and method for replicating a distributed computer system state among a plurality of deterministic event processing engines are disclosed. A sender module receives a plurality of input events or input event streams and generates a serialized message sequence describing an order in which input events are processed. The serialized message sequence is then transmitted to a plurality of deterministic event processing engines for processing. As the event processing engines are deterministic, each event processing engine produces the same ordered sequence responsive to the received serialized message sequence. The ordered sequences from each deterministic event processing engine are transmitted to a merger module which generates an output from the plurality of ordered sequences. The merger module removes one or more redundant ordered sequences and associates the resulting output with a client device.
-
Citations
27 Claims
-
1. A system for complex event processing comprising:
-
a sender module for receiving an input event and for generating a serialized message sequence from the input event; a plurality of deterministic event processing engines for processing the serialized message sequence and generating a plurality of redundant ordered sequences; a merger module for receiving the plurality of redundant ordered sequences and for generating an output result for transmission; and wherein at least one of the sender module, deterministic event processing engines and merger module comprises at least one hardware component. - View Dependent Claims (5, 6)
-
- 2. The system of claim wherein the sender module stores a copy of the input event and an ordering of the input event.
-
7. A method executable by a processor of a computer for complex event processing, the method comprising:
-
receiving an input event; generating a serialized message sequence including the received input event; processing the serialized message sequence using a plurality of event processing engines to generate a plurality of redundant ordered sequences; and generating an output result from one of the plurality of redundant ordered sequences. - View Dependent Claims (8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18)
-
-
19. A computer program product for complex event processing, the computer program product comprising a non-transitory computer-readable medium containing computer program code for performing the method comprising:
-
receiving an input event; generating a serialized message sequence including the received input event; processing the serialized message sequence using a plurality of event processing engines to generate a plurality of redundant ordered sequences; and generating an output result from one of the plurality of redundant ordered sequences. - View Dependent Claims (20, 21, 22, 23, 24, 25, 26)
-
-
27. A system for complex event processing comprising:
-
anon-transitory computer-readable medium storing computer-executable code, the computer-executable code comprising; a sender module for receiving an input event and for generating a serialized message sequence from the input event; a plurality of deterministic event processing engines for processing the serialized message sequence and generating a plurality of redundant ordered sequences; and a merger module for receiving the plurality of redundant ordered sequences, generating an output result for transmission and storing a current position (1) associated with the input event and (2) specifying a position of processing in one of the plurality of redundant ordered sequences.
-
Specification