US 2024/0179102 A1Published application

Systems and methods for managing message queuing

AssigneePushnami LLC

InventorsMitchell Taylor, Emerson Smith

Life of this patent

Estimating the term…

Loading patent…

Abstract

Improved messaging systems are disclosed. Embodiments allow message producers to access or create producer reservations in a queue coordination data store corresponding to a campaign. The producer reservations reflect a workload and a campaign aspect. A message producer can apply a usage strategy in resource selection which may optimize selection of queueing resources considering existing work volume for those message queues or aspects of the campaign. Message consumers may select message queues from which to consume messages using data in the queue coordination data store. A message consumer may apply a usage strategy in resource selection which may optimize selection of queueing resources considering existing work volume for those message queues of aspects of the campaign.

Claims21

Dependent claims

A system, comprising:

a queue coordination data store;
a message producer adapted to execute a campaign by:
determining a workload associated with the campaign;
determining a number of queues for the campaign;
reserving a first set of message queues for the campaign in the queue coordination data store, wherein the first set of message queues comprise the determined number of message queues for the campaign and the first set of message queues are reserved by creating a producer reservation in the queue coordination data store for each message queue of the first set of message queues, each producer reservation for a message queue of the first set of message queues comprising an association between an aspect of the campaign, an identifier for the message queue, and the workload;
producing messages associated with the campaign to the first set of message queues;
a message consumer adapted to consume messages from the message queues of the messaging system by:
determining a consumer queue pool at an interval based on workloads associated with producer reservations in the queue coordination data store, wherein the consumer queue pool comprises a second set of the message queues of the messaging system;
reserving the second set of message queues by creating a consumer reservation in the queue coordination data store for each message queue of the second set of message queues, each consumer reservation for each message queue of the second set of message queues comprising an association between an identifier for the message consumer and the identifier for the message queue;
and
reading messages from the second set of message queues.

8 more elements

A method, comprising:

at a message producer adapted to execute a campaign:
determining a workload associated with the campaign;
determining a number of queues for the campaign;
reserving a first set of message queues for the campaign in the queue coordination data store, wherein the first set of message queues comprise the determined number of message queues for the campaign and the first set of message queues are reserved by creating a producer reservation in the queue coordination data store for each message queue of the first set of message queues, each producer reservation for a message queue of the first set of message queues comprising an association between an aspect of the campaign, an identifier for the message queue, and the workload;
producing messages associated with the campaign to the first set of message queues;
at a message consumer adapted to consume messages from the message queues of the messaging system:
determining a consumer queue pool at an interval based on workloads associated with producer reservations in the queue coordination data store, wherein the consumer queue pool comprises a second set of the message queues of the messaging system;
reserving the second set of message queues by creating a consumer reservation in the queue coordination data store for each message queue of the second set of message queues, each consumer reservation for each message queue of the second set of message queues comprising an association between an identifier for the message consumer and the identifier for the message queue;
and
reading messages from the second set of message queues.

7 more elements

A non-transitory computer readable medium, comprising instructions for:

at a message producer adapted to execute a campaign:
determining a workload associated with the campaign;
determining a number of queues for the campaign;
reserving a first set of message queues for the campaign in the queue coordination data store, wherein the first set of message queues comprise the determined number of message queues for the campaign and the first set of message queues are reserved by creating a producer reservation in the queue coordination data store for each message queue of the first set of message queues, each producer reservation for a message queue of the first set of message queues comprising an association between an aspect of the campaign, an identifier for the message queue, and the workload;
producing messages associated with the campaign to the first set of message queues;
at a message consumer adapted to consume messages from the message queues of the messaging system:
determining a consumer queue pool at an interval based on workloads associated with producer reservations in the queue coordination data store, wherein the consumer queue pool comprises a second set of the message queues of the messaging system;
reserving the second set of message queues by creating a consumer reservation in the queue coordination data store for each message queue of the second set of message queues, each consumer reservation for each message queue of the second set of message queues comprising an association between an identifier for the message consumer and the identifier for the message queue;
and
reading messages from the second set of message queues.

7 more elements

Dependencies are inferred from the claim text.