Method and system for processing raw financial data streams to produce and distribute structured and validated product offering data to subscribing clients
First Claim
1. A method for processing information, the method comprising:
- in a client manager;
establishing communication sessions with a plurality of clients;
connecting to at least one broadcast data stream;
receiving on a connected broadcast data stream a current state for a specific data object;
updating an object pool cache to reflect the current state of the specific data object; and
transmitting the current state of the specific data object to a set of clients selected from the plurality of clients, comprising, for each respective client in the set of clients;
placing at least one state event in a respective client event queue, the at least one state event including the current state of the corresponding specific data objects and embedded functions that encompass a basic set of aggregation and combination rules for state events;
deriving a client event from the at least one state event prior to transmission of the client event to the respective client, wherein the deriving of the client event occurs upon placement of the at least one state event in the client event queue or upon removal of the at least one state event from the client event queue; and
subsequently transmitting the client event derived from the at least one state event in the client event queue to the respective client,wherein said embedded functions that encompass a basic set of aggregation and combination rules for state events are removed from the client event.
0 Assignments
0 Petitions
Accused Products
Abstract
A method and system is disclosed for processing information provided from various content providers in the form objects having states subject to periodic updates. Formatted information indicating a current state of the objects are delivered to subscribing clients in substantially real-time. An information manager module is configured to receiving raw data objects from the content providers, format the information, and broadcast current state information on various broadcast data stream. A client manager module supports multiple client communication sessions and connects to at least one broadcast data stream. Current state information received on a broadcast data stream is processed and transmitted to specific clients in accordance with processing rules specified in the client profiles.
76 Citations
19 Claims
-
1. A method for processing information, the method comprising:
in a client manager; establishing communication sessions with a plurality of clients; connecting to at least one broadcast data stream; receiving on a connected broadcast data stream a current state for a specific data object; updating an object pool cache to reflect the current state of the specific data object; and transmitting the current state of the specific data object to a set of clients selected from the plurality of clients, comprising, for each respective client in the set of clients; placing at least one state event in a respective client event queue, the at least one state event including the current state of the corresponding specific data objects and embedded functions that encompass a basic set of aggregation and combination rules for state events; deriving a client event from the at least one state event prior to transmission of the client event to the respective client, wherein the deriving of the client event occurs upon placement of the at least one state event in the client event queue or upon removal of the at least one state event from the client event queue; and subsequently transmitting the client event derived from the at least one state event in the client event queue to the respective client, wherein said embedded functions that encompass a basic set of aggregation and combination rules for state events are removed from the client event. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18)
-
19. A system including at least one computer processor for processing information, the system comprising:
-
a client manager receiving at least one broadcast data stream as input, comprising an object pool cache, and connectable to a plurality of clients; the client manager, utilizing the at least one computer processor, configured to; establish communication sessions with a plurality of clients; connect to at least one broadcast data stream; receive on a connected broadcast data stream a current state for a specific data object; update an object pool cache to reflect the current state of the specific data object; and transmit the current state of the specific data object to a set of clients selected from the plurality of clients;
wherein the transmission of the current state of the specific data object to a set of clients further comprises, for each respective client in the set of clients;place at least one state event in a respective client event queue, the at least one state event including the current state of the corresponding specific data objects and embedded functions that encompass a basic set of aggregation and combination rules for state events; derive a client event from the at least one state event prior to transmission of the client event to the respective client, wherein the deriving of the client event occurs upon placement of the at least one state event in the client event queue or upon removal of the at least one state event from the client event queue; and subsequently transmit the client event derived from the at least one state event in the client event queue to the respective client, wherein said embedded functions that encompass a basic set of aggregation and combination rules for state events are removed from the client event.
-
Specification