Monitoring of subscriber message processing in a publish/subscribe messaging environment

Patent metadata

Field	Value
Publication number	US-9769109-B2
Application number	US-201615159574-A
Country	US
Kind code	B2
Filing date	May 19, 2016
Priority date	Apr 20, 2011
Publication date	Sep 19, 2017
Grant date	Sep 19, 2017

Abstract

A message associated with a subscription topic hosted by a publish/subscribe message tracking device is sent by the publish/subscribe message tracking device to at least one subscriber device that is registered to the subscription topic and configured to report action completion processing based upon content of the message. The action completion processing based upon content of the message by the at least one subscriber device is monitored.

First claim

What is claimed is:

1. A method, comprising:
sending, by a message tracking device, a message to at least one device that is configured to report internal processing of the message based upon content of the message;
determining to monitor the internal processing of the message based upon the content of the message in response to determining that action completion processing to monitor the internal processing of the message is enabled at the message tracking device and that the message comprises an indicator requesting the monitoring of the internal processing; and
monitoring the internal processing of the message based upon the content of the message by the at least one device.

2. The method of claim 1 , further comprising:
configuring the message with an instruction to report the internal processing of the message based upon the content of the message and action completion processing report criteria, where the action completion processing report criteria comprise at least one of a time-based constraint and an action completion processing report messaging constraint; and
where monitoring the internal processing of the message based upon the content of the message by the at least one device comprises monitoring the internal processing of the message based upon the configured action completion processing report criteria.

3. The method of claim 1 , where:
sending, by the message tracking device, the message to the at least one device that is configured to report the internal processing of the message based upon the content of the message comprises sending the message to the at least one device as a two-phase commit transaction; and
monitoring the internal processing of the message based upon the content of the message by the at least one device comprises receiving an action report message from the at least one device that comprises a commit status indicating the internal processing of the message by the at least one device, where the commit status comprises one of a commit indicator and a rollback indicator.

4. The method of claim 1 , where monitoring the internal processing of the message based upon the content of the message by the at least one device comprises:
receiving at least one action report message via an action reporting application programming interface (API) from the at least one device that comprises a status of the internal processing of the message by the at least one device.

5. The method of claim 1 , further comprising publishing monitoring results of the monitored internal processing comprising one of:
sending the monitoring results as an action report message to a first message queue specified within the message by a publisher device that published the message;
publishing the monitoring results to a report topic subscribed to by the publisher device that published the message and designated for publication of report messages; and
providing the monitoring results to at least one caller of an action reporting application programming interface (API).

6. The method of claim 1 , further comprising publishing monitoring results of the monitored internal processing, where the published monitoring results comprise:
a unique identifier associating the published monitoring results and the message;
a total number of devices eligible to receive the message;
a total number of the devices that have successfully completed the internal processing of the message based upon the content of the message;
a total number of the devices that have attempted but failed to complete the internal processing of the message based upon the content of the message; and
a total number of the devices that have not yet completed the internal processing of the message based upon the content of the message.

7. A system, comprising:
a communication module; and
a processor of a message tracking device programmed to:
send, via the communication module, a message to at least one device that is configured to report internal processing of the message based upon content of the message;
determine to monitor the internal processing of the message based upon the content of the message in response to determining that action completion processing to monitor the internal processing of the message is enabled at the message tracking device and that the message comprises an indicator requesting the monitoring of the internal processing; and
monitor the internal processing of the message based upon the content of the message by the at least one device.

8. The system of claim 7 , where the processor is further programmed to:
configure the message with an instruction to report the internal processing of the message based upon the content of the message and action completion processing report criteria, where the action completion processing report criteria comprise at least one of a time-based constraint and an action completion processing report messaging constraint; and
where, in being programmed to monitor the internal processing of the message based upon the content of the message by the at least one device, the processor is programmed to monitor the internal processing of the message based upon the configured action completion processing report criteria.

9. The system of claim 7 , where, in being programmed to:
send, via the communication module, the message to the at least one device that is configured to report the internal processing of the message based upon the content of the message, the processor is programmed to send the message to the at least one device as a two-phase commit transaction; and
monitor the internal processing of the message based upon the content of the message by the at least one device, the processor is programmed to receive, via the communication module, an action report message from the at least one device that comprises a commit status indicating the internal processing of the message by the at least one device, where the commit status comprises one of a commit indicator and a rollback indicator.

10. The system of claim 7 , where, in being programmed to monitor the internal processing of the message based upon the content of the message by the at least one device, the processor is programmed to:
receive, via the communication module, at least one action report message via an action reporting application programming interface (API) from the at least one device that comprises a status of the internal processing of the message by the at least one device.

11. The system of claim 7 , where the processor is further programmed to publish monitoring results of the monitored internal processing, comprising the processor being programmed to one of:
send, via the communication module, the monitoring results as an action report message to a first message queue specified within the message by a publisher device that published the message;
publish the monitoring results to a report topic subscribed to by the publisher device that published the message and designated for publication of report messages; and
provide, via the communication module, the monitoring results to at least one caller of an action reporting application programming interface (API).

12. The system of claim 7 , where the processor is further programmed to publish monitoring results of the monitored internal processing, where the published monitoring results comprise:
a unique identifier associating the published monitoring results and the message;
a total number of devices eligible to receive the message;
a total number of the devices that have successfully completed the internal processing of the message based upon the content of the message;
a total number of the devices that have atte

Assignees

• IBM

Inventors

• Beardsmore Anthony P
• Levell Jonathan

Classifications

• G06F9/542 Primary

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• H04L67/10

  in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46) · CPC title

• H04L43/08

  Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters · CPC title

• H04L41/02

  Standardisation; Integration · CPC title

• H04L51/34 Primary

  Electricity · mapped topic