Method for guaranteeing processing of messages in a continuous processing system
US7818757B1 · kind B1 · utility
Assignee
Inventors
Key dates
| Filing date | Jul 17, 2006 |
| Grant date | Oct 19, 2010 |
| Priority date | — |
| Expiry date | May 20, 2029 |
Classification
- Technology area (CPC G)Physics
- CPC primaryG06F11/1474
- WIPO fieldComputer technology
- WIPO sectorElectrical engineering
Abstract
A method for processing messages ensures that every message that enters a continuous processing system is fully processed in its entirety, even in the event of a failure within the system. Messages are pushed through an execution plan that includes a set of connected “primitives” that process the message, where the primitives may be distributed across a group of servers. Messages are pushed through in accordance with a protocol that does not permit unprocessed messages to be permanently lost as they travel from input sources, between primitives, and to output sources within the execution plan. The input queue, output queue, and state (if any) associated with each primitive are saved in persistent storage at select checkpoints. If a failure occurs on a server, the server, after it starts up again, restores the primitives on that server to the input queues, output queues, and states saved at the last applicable checkpoint.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.