ALLOCATING SPACE IN MESSAGE QUEUE FOR HETEROGENEOUS MESSAGES

• US 20120005688A1
• Filed: 06/30/2010
• Published: 01/05/2012
• Est. Priority Date: 06/30/2010
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Thyagaraj, Lohitashwa, Kesavan, Sanjay M., Gopalakrishna, Neeraj K.
• Granted Patent: US 8,479,219 B2
• Time in Patent Office: Days
• US Class Current: 719/314
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

Allocating space for storing heterogeneous messages in a message queue according to message classification. The classification may comprise message type, application type, network type, and so forth. Messages of multiple classification values may be queued in a single queue, referred to as a primary queue. When the allocated portion of the primary queue is reached for a particular message classification, then subsequent messages having that classification are sent to a secondary queue for queuing. The secondary queue also allocates space according to message classification. When space for a particular message classification becomes available in the primary queue, one or more messages having that classification may be moved from the secondary queue to the primary queue.

Claims

1. A method of queuing messages in allocated space of a message queue in a computing system, comprising:

determining a classification of a message to be queued in the message queue;

determining an amount of the space allocated to queuing messages having the determined classification;

determining an amount of the space in use for already-queued messages having the determined classification; and

if the determined amount of the space in use does not exceed the determined amount of the space allocated, then queuing the message in the message queue and updating the amount of the space in use, and otherwise, sending the message for queuing temporarily in a secondary queue.

2. The method according to claim 1, wherein a determined amount of space of the secondary queue is also allocated to queuing messages having the determined classification.

3. The method according to claim 1, wherein the classification is a message type of the message to be queued.

4. The method according to claim 1, wherein the message to be queued is classified according to an application which generated the message.

5. The method according to claim 1, wherein the message to be queued is classified according to a network type of a network over which the message is sent to the messaging queue to be queued.

6. The method according to claim 1, wherein the message to be queued is classified according to a target recipient of the message.

7. The method according to claim 1, further comprising responding to receiving the message for queuing temporarily in the secondary queue by:

determining an amount of space of the secondary queue which is allocated to queuing messages having the determined classification;

determining an amount of the space of the secondary queue which is in use for already-queued messages having the determined classification; and

if the determined amount of the space of the secondary queue which is in use does not exceed the determined amount of the space of the secondary queue which is allocated, then queuing the message in the secondary queue and updating the amount of the space of the secondary queue which is in use.

8. The method according to claim 7, further comprising generating a warning that the message cannot be queued when the determined amount of the space of the secondary queue which is in use exceeds or equals the determined amount of the space of the secondary queue which is allocated.

9. The method according to claim 1, further comprising iteratively evaluating whether the message queue has unused space in the space allocated to queuing messages having any of a plurality of classifications and, if so, determining whether any messages having that classification are queued in the secondary queue and, if so, moving at least one of the queued messages from the secondary queue to the message queue and updating the amount of the space of the message queue which is in use for already-queued messages having that classification and the amount of the space of the secondary queue which is in use for already-queued messages having that classification.

10. The method according to claim 1, further comprising iteratively evaluating, for each classification for which at least one message is queued in the secondary queue, whether the message queue has unused space in the space which is allocated to queuing messages having that classification and, if so, moving at least one of the queued messages from the secondary queue to the message queue and updating the amount of the space of the message queue which is in use for already-queued messages having that classification and the amount of the space of the secondary queue which is in use for already-queued messages having that classification.

11. A system for queuing messages in allocated space of a message queue in a computing system, comprising:

a computer comprising a processor; and

instructions which are executable, using the processor, to implement functions comprising;

determining a classification of a message to be queued in the message queue;

determining an amount of the space allocated to queuing messages having the determined classification;

determining an amount of the space in use for already-queued messages having the determined classification; and

if the determined amount of the space in use does not exceed the determined amount of the space allocated, then queuing the message in the message queue and updating the amount of the space in use, and otherwise, sending the message for queuing temporarily in a secondary queue.

12. The system according to claim 11, wherein the functions further comprise responding to receiving the message for queuing temporarily in the secondary queue by:

determining an amount of space of the secondary queue which is allocated to queuing messages having the determined classification;

determining an amount of the space of the secondary queue which is in use for already-queued messages having the determined classification; and

if the determined amount of the space of the secondary queue which is in use does not exceed the determined amount of the space of the secondary queue which is allocated, then queuing the message in the secondary queue and updating the amount of the space of the secondary queue which is in use.

13. A computer program product for queuing messages in allocated space of a message queue in a computing system, the computer program product comprising:

a computer readable storage medium having computer readable program code embodied therein, the computer readable program code configured for;

determining a classification of a message to be queued in the message queue;

determining an amount of the space allocated to queuing messages having the determined classification;

determining an amount of the space in use for already-queued messages having the determined classification; and

if the determined amount of the space in use does not exceed the determined amount of the space allocated, then queuing the message in the message queue and updating the amount of the space in use, and otherwise, sending the message for queuing temporarily in a secondary queue.

14. The computer program product according to claim 13, wherein the computer readable program code is further configured for responding to receiving the message for queuing temporarily in the secondary queue by:

determining an amount of space of the secondary queue which is allocated to queuing messages having the determined classification;

determining an amount of the space of the secondary queue which is in use for already-queued messages having the determined classification; and

if the determined amount of the space of the secondary queue which is in use does not exceed the determined amount of the space of the secondary queue which is allocated, then queuing the message in the secondary queue and updating the amount of the space of the secondary queue which is in use.