Dynamic granular messaging persistence

Patent metadata

Field	Value
Publication number	US-2016127300-A1
Application number	US-201614991903-A
Country	US
Kind code	A1
Filing date	Jan 8, 2016
Priority date	Nov 29, 2012
Publication date	May 5, 2016
Grant date	—

Abstract

Embodiments of the present invention provide a method, system and computer program product for dynamic, granular messaging persistence in a messaging system. In an embodiment of the invention, a method for dynamic, granular messaging persistence in a messaging system is provided. The method includes monitoring operational performance of a message broker and receiving a message for queuing in a message queue of the message broker. The method also includes parsing the message to extract different fields and corresponding priorities and selectively storing in fixed storage, data for corresponding ones of the different fields based upon consideration of corresponding ones of the priorities and the monitored operational performance. Finally, the method includes queuing the message in the message queue.

First claim

1 . A computer implemented method for dynamic, granular messaging persistence in a messaging system, the method comprising:
monitoring operational performance of a message broker executing in a memory of a host server; receiving a message for queuing in a message queue of the message broker; parsing the message to extract different fields; obtaining, from a schema, corresponding priorities for the extracted different fields, each of the priorities indicating a condition in which data in one of the different fields is to be persisted to fixed storage; selectively storing, in the fixed storage, data for corresponding ones of the different fields based upon consideration of corresponding ones of the priorities obtained from the schema and also the monitored operational performance; and, queuing the message in the message queue.

2 . The method of claim 1 , wherein the operational performance indicates a degree of resource utilization in the host server hosting the message broker.

3 . The method of claim 2 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is to be persisted in the fixed storage in response to detecting a low degree of resource utilization, but that the data in the corresponding one of the fields is not to be persisted in the fixed storage in response to detecting a high degree of resource utilization.

4 . The method of claim 2 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is to be persisted irrespective of a degree of utilization detected for the host server.

5 . The method of claim 2 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is never to be persisted irrespective of a degree of utilization detected for the host server.

6 . The method of claim 2 , wherein the resource utilization is processor utilization.

7 . The method of claim 2 , wherein the resource utilization is message throughput in the message broker.

8 . A message data processing system configured for dynamic, granular messaging persistence, the system comprising:
a host server communicatively linked to client servers over a computer communications network and also fixed storage; a message broker executing in a memory of the host server and brokering messages in a message queue for the client servers; and, a granular message persistence module coupled to the host server and comprising program code enabled to monitor operational performance of the message broker, parse a message received for queuing by the message broker in the message queue to extract different fields, obtain, from a schema, corresponding priorities for the extracted different fields, each of the priorities indicating a condition in which data in one of the different fields is to be persisted to the fixed storage, and selectively store, in the fixed storage, data for corresponding ones of the different fields based upon consideration of corresponding ones of the priorities obtained from the schema and also the monitored operational performance.

9 . The system of claim 8 , wherein the operational performance indicates a degree of resource utilization in the host server hosting the message broker.

10 . The system of claim 9 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is to be persisted in the fixed storage in response to detecting a low degree of resource utilization, but that the data in the corresponding one of the fields is not to be persisted in the fixed storage in response to detecting a high degree of resource utilization.

11 . The system of claim 9 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is to be persisted irrespective of a degree of utilization detected for the host server.

12 . The system of claim 9 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is never to be persisted irrespective of a degree of utilization detected for the host server.

13 . The system of claim 9 , wherein the resource utilization is processor utilization.

14 . The system of claim 9 , wherein the resource utilization is message throughput in the message broker.

15 . A computer program product for dynamic, granular messaging persistence in a messaging system, the computer program product comprising:
a non-transitory computer readable storage medium having computer readable program code embodied therewith that when executed causes a host server to: monitor operational performance of a message broker executing in a memory of the host server; receive a message for queuing in a message queue of the message broker; parse the message to extract different fields; obtain, from a schema, corresponding priorities for the extracted different fields, each of the priorities indicating a condition in which data in one of the different fields is to be persisted to fixed storage; selectively store, in the fixed storage, data for corresponding ones of the different fields based upon consideration of corresponding ones of the priorities obtained from the schema and also the monitored operational performance; and, queue the message in the message queue.

16 . The computer program product of claim 15 , wherein the operational performance indicates a degree of resource utilization in the host server hosting the message broker.

17 . The computer program product of claim 16 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is to be persisted in the fixed storage in response to detecting a low degree of resource utilization, but that the data in the corresponding one of the fields is not to be persisted in the fixed storage in response to detecting a high degree of resource utilization.

18 . The computer program product of claim 16 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is to be persisted irrespective of a degree of utilization detected for the host server.

19 . The computer program product of claim 16 , wherein at least one of the priorities indicates that data in a corresponding one of the fields is never to be persisted irrespective of a degree of utilization detected for the host server.

20 . The computer program product of claim 16 , wherein the resource utilization is processor utilization.

21 . The computer program product of claim 16 , wherein the resource utilization is message throughput in the message broker.

22 . The method of claim 1 , wherein the corresponding priorities indicated in the schema are values.

23 . The method of claim 1 , wherein the corresponding priorities indicated in the schema are rules.

Assignees

• IBM

Inventors

• Granshaw David
• Massey Sam T
• Mcginnes Daniel
• Ross Martin
• Schofield Richard
• Stirling Craig

Classifications

• H04L51/226

  Delivery according to priorities · CPC title

• G06Q10/107 Primary

  Computer-aided management of electronic mailing [e-mailing] · CPC title

• H04L51/26 Primary

  Electricity · mapped topic

• H04L51/234

  for tracking messages · CPC title

• H04L51/00

  User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail · CPC title