Application of system level policy in message oriented middleware

• US 8,577,976 B2
• Filed: 04/27/2011
• Issued: 11/05/2013
• Est. Priority Date: 04/27/2010
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bhasin, Rohit, Gale, Martin J., Roberts, Matthew I.
• Primary Examiner(s): Zong, Ruolei
• Application Number:
  US13/095,816
• Publication Number:
  US 20120005286A1
• Time in Patent Office: 923 Days
• Field of Search: 709/206, 709220-221, 709223-226, 379 9301- 9337
• US Class Current: 709/206
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

One or more policies to be applied to a set of one or more messages in a message oriented middleware are defined. Metrics of the message oriented middleware are monitored. Application of a policy in response to a trigger condition being satisfied is initiated. Application of the policy applies actions across the set of one or more messages.

Claims

1. A computer program product for application of system level policy in message oriented middleware comprising a computer-readable storage device in which computer-executable instructions are stored, which instructions, when executed by a computer, cause the computer to:

define one or more policies to be applied to a set of one or more messages in the message oriented middleware;

monitor metrics of the message oriented middleware;

initiate application of a policy in response to a trigger condition being satisfied; and

where application of the policy applies actions across the set of one or more messages, applies the defined policy to an abstract representation of at least one message to allow manipulation of the at least one message without loading the whole at least one message into memory, and the abstract representation of the at least one message allows only loading of metadata of the at least one message.

2. The computer program product of claim 1, where the defined policy defines a quality of service (QoS) policy.

3. The computer program product of claim 1, where the defined policy comprises one or more trigger conditions for activating the defined policy, one or more actions to be applied, and a link between the one or more trigger conditions and the one or more actions.

4. The computer program product of claim 1, where the computer-executable instructions, when executed by the computer, cause the computer to apply actions at selected points in the message oriented middleware comprising at least one of:

at messages stored on a queue, at durable or non-durable subscription to messages, at transmission streams between components in a distributed messaging system, message buffers, and a group of the above points.

5. The computer program product of claim 1, where the defined policy modifies a quality of service (QoS) of at least one of the set of one or more messages after the at least one of the set of one or more messages is stored in response to the trigger condition being satisfied.

6. The computer program product of claim 1, where the computer-executable instructions, when executed by the computer, cause the computer to apply system level mediation to the set of one or more messages.

7. The computer program product of claim 1, where the computer-executable instructions, when executed by the computer, cause the computer to apply the defined policy by access to metadata about a point of queuing of at least one message within a queue and an ability to modify behavior of the queue.

8. The computer program product of claim 1, where, in causing the computer to monitor the metrics of the message oriented middleware, the computer-executable instructions, when executed by the computer, cause the computer to monitor internal and external metrics.

9. A system for application of system level policy in message oriented middleware, comprising:

a memory that stores a defined policy; and

a processor that executes;

a messaging server;

a monitoring component that monitors metrics of the message oriented middleware; and

a determining component that initiates application of the defined policy in response to a trigger condition being satisfied; and

where application of the defined policy applies actions across a set of one or more messages, the determining component applies the defined policy to an abstract representation of at least one message to allow manipulation of the at least one message without loading the whole at least one message into the memory, and the abstract representation of the at least one message allows only loading of metadata of the at least one message.

10. The system of claim 9, where the defined policy defines a quality of service (QoS) policy.

11. The system of claim 9, where the defined policy comprises one or more trigger conditions for activating the defined policy, one or more actions to be applied, and a link between the one or more trigger conditions and the one or more actions.

12. The system of claim 9, where the determining component applies actions at selected points in the message oriented middleware comprising at least one of:

at messages stored on a queue, at durable or non-durable subscription to messages, at transmission streams between components in a distributed messaging system, message buffers, and a group of the above points.

13. The system of claim 9, where the defined policy modifies a quality of service (QoS) of at least one of the set of one or more messages after the at least one of the set of one or more messages is stored in response to the trigger condition being satisfied.

14. The system of claim 9, where the determining component applies system level mediation to the set of one or more messages.

15. The system of claim 9, where the determining component applies the defined policy by access to metadata about a point of queuing of at least one message within a queue and an ability to modify behavior of the queue.

16. The system of claim 9, where the monitoring component monitors metrics of the message oriented middleware comprising internal and external metrics.