| 摘要 |
A system and method provides efficient message processing of assets by placing all messages in a queue as they are received from an information feed. Messages are grouped according to the entities with which they are associated and messages within each group are sorted according to the time the message was generated by the information feed. Messages are processed in the order in which they were generated using a system that accounts for delayed or out-of-order messages by evaluating the message state, comparing it to the last stored state, and delaying the processing of messages arriving ahead of earlier-generated messages.
|
