发明名称 |
Publish and subscribe system including buffer |
摘要 |
Systems and methods for delivering a plurality of trading data messages to a server in connection with the monitoring the trading of financial instruments are provided. A listener subscribes to a subset of the plurality of trading data messages generated by market participants or components within the trading platform. A buffer receives the subset of the plurality of trading data messages and stores the subset of the plurality of trading data messages. A server, such as a live alerts server, receives the subset of the plurality of trading data messages stored from the buffer and analyzes the subset of the plurality of trading data. |
申请公布号 |
US8812393(B2) |
申请公布日期 |
2014.08.19 |
申请号 |
US201313897077 |
申请日期 |
2013.05.17 |
申请人 |
Chicago Mercantile Exchange Inc. |
发明人 |
Doornebos Jacob;Moran James P;King Michael |
分类号 |
G06Q40/00;G06F15/16;G06Q40/04;G06Q40/06;G06Q10/10 |
主分类号 |
G06Q40/00 |
代理机构 |
Banner & Witcoff Ltd. |
代理人 |
Banner & Witcoff Ltd. |
主权项 |
1. A system for delivering a plurality of messages to an external client device, the system comprising:
a trading engine configured to generate the plurality of messages and associate each of the plurality of messages with an attribute to define at least a first class of messages and a second class of messages; a communication bus configured to receive the plurality of messages from the trading engine and asynchronously deliver the plurality of messages; a plurality of listeners coupled to the communication bus and configured to subscribe to and receive the first class of messages and the second class of messages; and a buffering system configured to temporarily store in a non-indexed collection the plurality of messages received from the plurality of listeners for a first time period and configured to provide at least one of the stored messages to the external client device based upon a request from the external client device wherein the buffering system is configured to determine when one of the plurality of listeners misses a message and to store a corresponding message received from a corresponding redundant listener. |
地址 |
Chicago IL US |