Streaming platform reader

A computer implemented method comprising:

• executing, by a processor coupled with a streaming platform, a set of reader threads, each associated with one partition of the streaming platform and configured to retrieve electronic messages therefrom, each electronic message comprising data indicative of when the electronic message was generated by any of a plurality of sources, and wherein the processor transmits an end of partition signal to the reader thread when the partition contains no electronic messages;
• storing, by a set of queues stored in a memory and coupled with the reader threads, electronic messages or an end of partition signal retrieved by one of the reader threads in a sequence that the electronic messages are retrieved, and wherein each queue includes a first position that stores the earliest generated electronic message of the electronic messages stored therein;
• and
• providing to a consuming application requesting electronic messages by a writer thread executed by the processor and which is controlled by gate control logic, upon determining that each of the queues contains an electronic message or an end of partition signal, the earliest generated electronic message of all of the electronic result messages currently stored in the first positions.

A system comprising:

• means for executing, coupled with a streaming platform, a set of reader threads, each associated with one partition of the streaming platform and configured to retrieve electronic messages therefrom, each electronic message comprising data indicative of when the electronic message was generated by any of a plurality of sources, and wherein the processor transmits an end of partition signal to the reader thread when the partition contains no electronic messages;
• means for storing, by a set of queues stored in a memory and coupled with the reader threads, electronic messages or an end of partition signal retrieved by one of the reader threads in a sequence that the electronic messages are retrieved, and wherein each queue includes a first position that stores the earliest generated electronic message of the electronic messages stored therein;
• and
• means for providing to a consuming application requesting electronic messages by a writer thread which is controlled by gate control logic, upon determining that each of the queues contains an electronic message or an end of partition signal, the earliest generated electronic message of all of the electronic result messages currently stored in the first positions.