METHOD AND SYSTEM FOR MONITORING MESSAGE OBJECTS SENT FROM A CLIENT TO INVOKE OPERATIONS ON A SERVER IN A DISTRIBUTED COMPUTING ENVIRONMENT

• US 20130110908A1
• Filed: 11/30/2011
• Published: 05/02/2013
• Est. Priority Date: 11/02/2011
• Status: Active Grant

• Current Assignee: Software AG
• Original Assignee: Guido Trensch, Rolf Bahlke, Wolfgang Schmidt
• Inventors: Trensch, Guido, Schmidt, Wolfgang, BAHLKE, Rolf
• Granted Patent: US 9,213,620 B2
• Time in Patent Office: Days
• US Class Current: 709/203
• CPC Class Codes: G06F 11/3006 where the computing system is distributed, e.g. networked systems, clusters, multiprocessor systems multiprogramming arrangements G06F9/46; allocation of resources G06F9/50
• CPC Class Codes: G06F 11/302 where the computing system component is a software system
• CPC Class Codes: G06F 11/3065 Monitoring arrangements determined by the means or processing involved in reporting the monitored data error or fault reporting or logging G06F11/0766
• CPC Class Codes: G06F 11/3409 for performance assessment
• CPC Class Codes: G06F 11/3476 Data logging G06F11/14, G06F11/2205 take precedence
• CPC Class Codes: G06F 11/3495 for systems
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 43/0852 Delays
• CPC Class Codes: H04L 43/10 Active monitoring, e.g. heartbeat, ping or trace-route
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46

Abstract

Certain example embodiments relate to a method of monitoring a message object sent from a client to invoke an operation on a server in a distributed computing environment. Upon receipt of the message object at a measurement point, measurement data is produced. The measurement data is inserted into the message object.

Claims

1. A method of monitoring a message object sent from a client to invoke an operation on a server in a distributed computing environment, the method comprising:

(a) upon receipt of the message object at a measurement point, producing measurement data; and

(b) inserting the measurement data into the message object.

2. The method of claim 1, wherein the measurement data comprises information about a delay time, transport time and/or retention time of the message object.

3. The method of claim 1, wherein (b) comprises appending the measurement data to measurement data that already exists in the message object.

4. The method of claim 1, wherein the message object comprises at least one message extension in which the measurement data is inserted, the at least one message extension being separate from a payload of the message object.

5. The method of claim 1, further comprising:

extracting existing measurement data from the message object;

wherein

(a) comprises performing at least one calculation on the extracted existing measurement data for producing the measurement data.

6. The method of claim 1, further comprising:

receiving the message object at a message endpoint; and

sending the measurement data comprised in the message object to a data collector.

7. The method of claim 1, wherein the message object is passed between at least one client and at least one server over at least one broker in the distributed computing environment;

and

wherein the at least one client, the at least one server and/or the at least one broker comprises at least one respective measurement point (M) for producing measurement data.

8. A non-transitory computer readable storage medium tangibly storing a computer program comprising instructions for implementing a method according to claim 1.

9. A system for monitoring a message object sent from a client to invoke an operation on a server in a distributed computing environment, wherein the system comprises:

(a) at least one measurement point, configured to receive the message object and for producing measurement data;

wherein

(b) the at least one measurement point being further configured to insert the measurement data into the message object.

10. The system of claim 9, wherein the at least one measurement point is measurement data comprising information about a delay time, transport time and/or retention time of the message object.

11. The system of claim 9, herein the at least one measurement point configured to append the measurement data to measurement data that already exists in the message object.

12. The system of claim 9, wherein the message object comprises at least one message extension in which the measurement data is inserted, the at least one message extension being separate from a payload of the message object.

13. The system of claim 9, wherein the at least one measurement point is further configured to:

extract existing measurement data from the message object; and

perform at least one calculation on the extracted existing measurement data for producing the measurement data.

14. The system of claim 9, wherein the system further comprises a message endpoint configured to:

receive the message object; and

send the measurement data comprised in the message object to a data collector.

15. The system of claim 9, wherein the system further comprises at least one client, at least one server and at least one broker between which the message object is passed;

wherein the at least one client, the at least one server and/or the at least one broker comprise at least one respective measurement point for producing measurement data.