Patent ID: 8069264
Filing Date: 2011-11-29
Classification: G06Q

Abstract:
1. A system including at least one computer processor for processing raw data streams carrying a plurality of raw data objects containing information related to financial product offerings and subject to periodic updates, and for delivering substantially real-time offer updates to a plurality of clients via a data communication network, the system comprising: at least one information manager connected to the raw data streams and providing at least one broadcast data stream as output; and at least one client manager receiving the at least one broadcast data stream as input and transmitting the offer updates to the plurality of clients; the at least one information manager comprising: (a) a translator configured to receive the raw data objects as input and generate raw events comprising a set of name-value pairs derived from data in the raw data objects; (b) a processing database having object typing and formatting rules stored therein; (c) an offer processor connected to the processing database and configured to, in response to the receipt of a raw event: (d) an object storage pool configured to store a plurality of formatted data objects therein; (e) an offer pool manager connected to the object storage pool and configured to, upon receipt of an external event: the at least one client manager comprising: (a) at least one object state manager, each object state manager connected to a respective broadcast data stream, comprising an associated object cache and subscriber data indicating subscribers to the respective data input stream, and configured to: receive a data object on the connected input data stream related to a specific product offering, update the state of the specific product offering in associated object pool cache in accordance with the state changed indicated in the received data object, and generate an object event directed to subscribers of the respective data input stream indicating the state change for the specific product offering in accordance with the subscriber data; (b) a plurality of client session modules, each client session module being in communication with a respective client and configured to: receive object events generated by object state managers connected to an broadcast data stream to which the respective client has subscribed, upon receiving an object event, evaluate client object rules against the object event, the object rules selected in accordance with the particular broadcast data stream associated with the object event, and generate a state event from the object event indicating the changed state of the specific data object to the respective client in response to a positive evaluation; (c) a plurality of delivery managers, each delivery manager being associated with a respective client session module and configured to: (d) a client session manager having access to a plurality of client profiles, each client profile containing data stream subscription information and related client object rules, the client manager configured to: