US 9,432,445 B1Granted

System and method of maintaining an enqueue rate of data messages into a set of queues

AssigneeSprint Communications Company L.P.

InventorMark D. Leonard

Life of this patent

Estimating the term…

Loading patent…

Abstract

A system comprises a component which receives an initial status message, from a primary queue manager, comprising a rate of data messages moving into a primary queue. The component detects that a primary queue rate is below a predetermined range based on the received initial status message. The component increases the weight of the primary queue in response to detecting that the primary queue rate provided by the initial status message is below the predetermined range. The component receives a subsequent status message, from the primary queue manager, comprising the rate of data messages moving into the primary queue. The component detects that the primary queue has a rate below the predetermined range based on the received subsequent status message. The component activates a secondary queue in response to detecting that the primary queue rate provided by the subsequent status message is below the predetermined range.

Claims20

Dependent claims

A system for maintaining an enqueue rate of data messages into a set of queues, the system comprising:

a server coupled to a cluster of primary servers and a cluster of secondary servers, the server comprising:
a processor coupled to a non-transitory memory storing a cluster server repository component stored as a set of computer instructions that upon execution by the processor configures the server to:
receive an initial status message, from a primary queue manager executing from non-transitory memory in the cluster of primary servers, comprising the enqueue rate of data messages moving into a primary queue of the primary queue manager,
detect that the primary queue has an enqueue rate below a predetermined range based on the received initial status message,
increase a weight of the primary queue in response to detecting that the enqueue rate of the primary queue provided by the initial status message is below the predetermined range,
receive a subsequent status message, from the primary queue manager, comprising the enqueue rate of data messages moving into the primary queue after the weight of the primary queue is increased,
detect that the primary queue has an enqueue rate below the predetermined range based on the received subsequent status message, and
activate, in the cluster of secondary servers, a secondary queue of a secondary queue manager in response to detecting that the enqueue rate of the primary queue provided by the subsequent status message is below the predetermined range, wherein the secondary queue manager executes from non-transitory memory in the cluster of secondary servers.

5 more elements

A method of maintaining an enqueue rate of data messages into a set of queues, the method comprising:

receiving, by a server executing a cluster server repository component from non-transitory memory, an initial status message from a primary queue manager executing from non-transitory memory in a cluster of primary servers, the initial status message comprising the enqueue rate of data messages moving into a primary queue of the primary queue manager;
detecting, by the server executing the cluster server repository component, that the primary queue has an enqueue rate below a predetermined range based on the received initial status message;
increasing, by the server executing the cluster server repository component, a weight of the primary queue in response to detecting that the enqueue rate of the primary queue provided by the initial status message is below the predetermined range;
receiving, by the server executing the cluster server repository component, a subsequent status message, from the primary queue manager, comprising the enqueue rate of data messages moving into the primary queue after the weight of the primary queue is increased;
detecting, by the server executing the cluster server repository component, that the primary queue has an enqueue rate below the predetermined range based on the received subsequent status message;
and
activating, in a cluster of secondary servers by the server executing the cluster server repository component, a secondary queue of a secondary queue manager in response to detecting that the enqueue rate of the primary queue provided by the subsequent status message is below the predetermined range, wherein the secondary queue manager executes from non-transitory memory in the cluster of secondary servers.

4 more elements

A method of maintaining an enqueue rate of data messages into a set of queues, the method comprising:

receiving, by a server executing a cluster server repository component from non-transitory memory, an initial status message from a primary queue manager executing from non-transitory memory in a cluster of primary servers, the initial status message comprising the enqueue rate of data messages moving into a primary queue of the primary queue manager;
detecting, by the server executing the cluster server repository component, that the primary queue has an enqueue rate above a predetermined range based on the received initial status message;
decreasing, by the server executing the cluster server repository component, the enqueue rate of the primary queue in response to detecting that the enqueue rate of the primary queue provided by the initial status message is above the predetermined range;
receiving, by the server executing the cluster server repository component, a subsequent status message, from the primary queue manager, comprising the enqueue rate of data messages moving into the primary queue;
detecting, by the server executing the cluster server repository component based on the received subsequent status message, that the primary queue has an enqueue rate within the predetermined range while a weight of the primary queue is below a threshold;
and
activating, in a cluster of secondary servers by the server executing the cluster server repository component, a secondary queue of a secondary queue manager in response to detecting that the enqueue rate of the primary queue is within the predetermined range while the weight of the primary queue is below the threshold, wherein the secondary queue manager executes from non-transitory memory in the cluster of secondary servers.

4 more elements

Dependencies are inferred from the claim text.