Method to Efficiently and Reliably Process Ordered User Account Events in a Cluster
AssigneeInternational Business Machines Corporation
InventorMark Braksator
Life of this patent
Estimating the term…
Abstract
A method, apparatus, and computer program product uses a SELECT FOR UPDATE, to pick up events from a TARGET_EVENT table. Selected events are reserved for processing by a cluster node which triggers a query. PICKUP_TIME and SERVER_ID values are inserted for each of the events picked from the TARGET_EVENT table. The events are grouped by TARGET and UID while preserving a relative order in an overall event sequence. A group of events is then submitted for processing.
Claims20
A computer implemented method comprising:
- using a SELECT FOR UPDATE statement, picking up, by a processor, events from a TARGET_EVENT table;
- reserving selected events for processing by a cluster node which triggers a query;
- inserting, by the processor, PICKUP_TIME values and SERVER_ID values for each of the events;
- grouping, by the processor, the events by a TARGET and a UID while preserving a relative order in an overall event sequence;
- and
- submitting, by the processor, at least one group of events.
A computer system comprising:
- a processor connected to a database, an application server cluster, a remote account request target broker, and a number of remote targets, the database and an application server cluster storing instructions configured to cause the process to perform steps comprising:
- using a SELECT FOR UPDATE statement, picking up, by the processor, events from a TARGET_EVENT table;
- reserving selected events for processing by a cluster node which triggered a query;
- inserting, by the processor, PICKUP_TIME values and SERVER_ID values for each of the events;
- grouping, by the processor, the events by a TARGET and a UID while preserving a relative order in an overall event sequence;
- and
- submitting, by the processor, at least one group of events.
A computer program product for dynamically injecting a wait function into a program, the computer program product comprising a computer-readable storage medium having program instructions executable by a computer to cause the computer to perform a method comprising:
- using a SELECT FOR UPDATE, picking up, by a processor, events from a TARGET_EVENT table;
- reserving selected events for processing by a cluster node which triggered a query;
- inserting, by the processor, PICKUP_TIME values and SERVER_ID values for each of the events;
- grouping, by the processor, the events by a TARGET and a UID while preserving a relative order in an overall event sequence;
- and
- submitting, by the processor, at least one group of events.
Dependencies are inferred from the claim text.