Publisher flow control and bounded guaranteed delivery for message queues
First Claim
Patent Images
1. A method comprising:
- in response to a publisher attempting to enqueue a message in a queue, determining whether a condition is satisfied;
wherein the publisher is a particular publisher of a plurality of publishers, wherein each publisher of the plurality of publishers enqueues messages in the queue;
wherein the queue is stored in volatile memory;
wherein the condition is based on the usage of the queue by the publisher; and
based on whether the condition is satisfied, deciding whether to enqueue the message in the queue, wherein deciding whether to enqueue the message in the queue comprises;
if the condition is satisfied, then restricting the publisher from enqueueing the message in the queue; and
if the condition is not satisfied, then allowing the publisher to enqueue the message in the queue;
wherein the method is performed by one or more computing devices.
0 Assignments
0 Petitions
Accused Products
Abstract
Techniques for managing messages in computer systems are provided. In one embodiment, in response to a publisher attempting to enqueue a message in a queue, a determination is made whether a condition is satisfied. The condition is based on the current usage of the queue by the publisher. Based on whether the condition is satisfied, a decision is made whether to enqueue the message in the queue. The decision whether to enqueue the message may comprise restricting the publisher from enqueueing any more messages in the queue until the same or a different condition is satisfied.
-
Citations
30 Claims
-
1. A method comprising:
-
in response to a publisher attempting to enqueue a message in a queue, determining whether a condition is satisfied; wherein the publisher is a particular publisher of a plurality of publishers, wherein each publisher of the plurality of publishers enqueues messages in the queue; wherein the queue is stored in volatile memory; wherein the condition is based on the usage of the queue by the publisher; and based on whether the condition is satisfied, deciding whether to enqueue the message in the queue, wherein deciding whether to enqueue the message in the queue comprises; if the condition is satisfied, then restricting the publisher from enqueueing the message in the queue; and if the condition is not satisfied, then allowing the publisher to enqueue the message in the queue; wherein the method is performed by one or more computing devices. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15)
-
-
16. A non-transitory machine-readable storage medium storing one or more sequences of instructions which, when executed by one or more processors, cause the one or more processors to perform steps comprising:
-
in response to a publisher attempting to enqueue a message in a queue, determining whether a condition is satisfied; wherein the publisher is a particular publisher of a plurality of publishers, wherein each publisher of the plurality of publishers enqueues messages in the queue; wherein the queue is stored in volatile memory; wherein the condition is based on the usage of the queue by the publisher; and based on whether the condition is satisfied, deciding whether to enqueue the message in the queue, wherein deciding whether to enqueue the message in the queue comprises; if the condition is satisfied, then restricting the publisher from enqueueing the message in the queue; and if the condition is not satisfied, then allowing the publisher to enqueue the message in the queue. - View Dependent Claims (17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30)
-
Specification