Patent ID: 9317347
Filing Date: 2016-04-19
CPC Classification: G06F,H04L

Claim Text:
1. A method comprising: receiving, at a queue of an application running within a distributed system, a data set from at least one other application running within the distributed system; determining that the data set received from the other application is incorporated in a bundle whose contents have yet to completely arrive at the queue of the application; gating, due at least in part to the data set being incorporated in the bundle, the data set at the queue of the application at least until the bundle's contents have completely arrived at the queue of the application; receiving, at the queue of the application, another data set incorporated in the bundle from the other application running within the distributed system; determining that the bundle's contents have completely arrived at the queue of the application based at least in part on receiving the other data set incorporated in the bundle; and in response to determining that the bundle's contents have completely arrived at the queue of the application, notifying the application that the bundle is ready for atomic delivery to the application such that the application is able to consume the bundle's contents on an as-needed basis, wherein the bundle comprises: modifying the bundle's contents to incorporate an updated version of the other data set without re-transferring any redundant versions of the bundle's contents from the other application to the queue of the application by: