Patent ID: 8732258

Claim:
A method for transporting telemetry data comprising: receiving, from a first client application executing on a first client, a first request comprising a first authentication credential for the first client, a first message comprising a plurality of telemetry data, and a first message priority for the first message; identifying a classification of the plurality of telemetry data; matching the classification to a back-end service configured to process telemetry data having the classification; routing the first request to a first physical node associated with the back-end service; authenticating, after routing the first request, the first request using the first authentication credential; parsing, after authenticating the first request, the first request to obtain a first command for storing the first message in a physical queue associated with the back-end service, wherein the physical queue comprises a plurality of messages received from the first client application and a plurality of messages received from a second client application executing on a second client; storing the first message in the physical queue; identifying a first virtual queue corresponding to the physical queue and comprising an entry for each of the plurality of messages received from the first client application, wherein the first virtual queue is not a component of the physical queue, and wherein the first virtual queue stores only entries corresponding to messages in the physical queue; identifying a second virtual queue corresponding to the physical queue and comprising an entry for each of the plurality of messages received from the second client application, wherein the second virtual queue is not a component of the physical queue, and wherein the second virtual queue stores only entries corresponding to messages in the physical queue; storing, in the first virtual queue, a first entry corresponding to the first message, wherein the first entry comprises the first message priority; receiving a second request from a first instance of a dispatch service executing on a third client registered with a data transport service executing on the first physical node, wherein the first instance of the dispatch service is associated with the back-end service, and wherein the second request comprises a second authentication credential for the third client; authenticating the second request using the second authentication credential; parsing the second request to obtain a second command for retrieving a second message stored in the physical queue; identifying the second message using the first virtual queue, wherein a second entry for the second message is stored in the first virtual queue, wherein the second entry comprises a second message priority for the second message, and wherein the second message priority is the highest message priority of any message priority in the first virtual queue; retrieving the second message from the physical queue; and sending a first response comprising the second message to the third client.