Back to results
US 2017/0302710 A1Published application
Scalable event stream data processing using a messaging system
AssigneeInternational Business Machines Corporation
InventorsTimothy M. Fox, Anyi Li, Scott J. McCallen, Douglas S. Meil, Kaveh Noorbakhsh
Life of this patent
Estimating the term…
Abstract
A system processes streaming data and includes at least one processor. The system may write streaming data received from a data source as messages in queues at a queuing cluster. The queuing cluster includes a coordinator node to direct the messages to non-coordinator nodes of the queuing cluster. The system may retrieve the data from the queues based on subscription of topics and store the retrieved data in a consumable repository.
Claims8
A computer-implemented method for processing streaming data, comprising:
- writing streaming data received from a data source as messages in queues at a queuing cluster, wherein the queuing cluster includes a coordinator node to direct the messages to non-coordinator nodes of the queuing cluster;
- retrieving the data from the queues based on subscription of topics;
- and
- storing the retrieved data in a consumable repository.
1 more element
Dependencies are inferred from the claim text.