US 11,816,512 B2
Event driven data processing system and method
Benjamen Pyle, Addison, TX (US); Rakesh Sanghvi, Addison, TX (US); and Robert Parker Freeburg, II, Addison, TX (US)
Assigned to CURANTIS SOLUTIONS, Addison, TX (US)
Filed by CURANTIS SOLUTIONS, Addison, TX (US)
Filed on Jul. 26, 2022, as Appl. No. 17/874,282.
Application 17/874,282 is a continuation of application No. 17/378,345, filed on Jul. 16, 2021, granted, now 11,429,460, issued on Aug. 30, 2022.
Prior Publication US 2023/0015780 A1, Jan. 19, 2023
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 9/54 (2006.01); G06F 9/46 (2006.01)
CPC G06F 9/542 (2013.01) [G06F 9/466 (2013.01)] 20 Claims
OG exemplary drawing
 
1. An event driven data processing system, comprising:
an event queue configured to receive an event from an event generator;
an event router stored in a non-transitory memory that when executed by a processor:
receives the event from the event queue,
determines that the event is to be multicast, and
routes the event to a multicast queue;
a multicast component stored in a non-transitory memory that when executed by a processor:
receives the event from the multicast queue,
creates a plurality of different events based on the event and based on a client configuration, and
transmits the plurality of different events to the event queue, wherein the event router is further configured to receive the plurality of different events from the event queue and transmit each of the plurality of different events to at least one context queue;
at least one contextualizer stored in a non-transitory memory that when executed by a processor:
receives one or more events of the plurality of different events from the at least one context queue,
for each event of the one or more received events:
accesses one or more context data sources to obtain additional context data for the event,
creates a supplemented event for the event by adding the additional context data to the event, and
stores the supplemented event created in an event datastore; and
a streaming component stored in a non-transitory memory that when executed by a processor streams each supplemented event from the event datastore for a period of time, wherein at least one streamed supplemented event is accessed by or provided to at least one of a consumer device, a webhook, an application programming interface, or a database.