Computer system to support failover in an event stream processing system

摘要

In a computing device supporting a failover in an event stream processing (ESP) system, an event block object is received. A first status of the computing device as active or standby is determined. When the first status is active, a second status of the computing device as newly active or not newly active is determined. Newly active is determined when the computing device is switched from a standby to an active status. When the second status is newly active, a last published event block object identifier that uniquely identifies a last published event block object is determined. A next event block object is selected from a non-transitory computer-readable medium accessible by the computing device. The next event block object has an event block object identifier that is greater than the determined last published event block object identifier. The selected next event block object is published to an out-messaging network device.

主权项

1. A non-transitory computer-readable medium having stored thereon computer-readable instructions that when executed by a computing device cause the computing device to:
receive an event block object from an event stream processing engine (ESPE), wherein the received event block object includes a unique identifier of the received event block object; determine a first status of the computing device as active or standby; when the first status of the computing device is determined to be active, determine a second status of the computing device as newly active or not newly active, wherein newly active is determined when the computing device is switched from a standby status to an active status; when the second status of the computing device is determined to be newly active,
determine a last published event block object identifier as an identifier that uniquely identifies a last published event block object;select a next event block object having an event block object identifier that is greater than the determined last published event block object identifier from the non-transitory computer-readable medium; andpublish the selected next event block object to an out-messaging network device; when the second status of the computing device is determined to be not newly active, publish the received event block object to the out-messaging network device; and when the first status of the computing device is determined to be standby, store the received event block object in the non-transitory computer-readable medium.