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

Patent metadata

Field	Value
Publication number	US-2016269348-A1
Application number	US-201615159574-A
Country	US
Kind code	A1
Filing date	May 19, 2016
Priority date	Apr 20, 2011
Publication date	Sep 15, 2016
Grant date	—

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 publish/subscribe message tracking device, a message associated with a subscription topic hosted 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; and monitoring the action completion processing based upon the content of the message by the at least one subscriber device.

2 . The method of claim 1 , further comprising determining to monitor the action completion processing based upon the content of the message in response to determining that the action completion processing is enabled at the publish/subscribe message tracking device and that the message comprises an indicator requesting the monitoring of the action completion.

3 . The method of claim 1 , further comprising:
configuring the message with an instruction to report the action completion processing 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 action completion processing based upon the content of the message by the at least one subscriber device comprises monitoring the action completion processing of the message based upon the configured action completion processing report criteria.

4 . The method of claim 1 , where:
sending, by the publish/subscribe message tracking device, the message associated with the subscription topic hosted by the publish/subscribe message tracking device to the at least one subscriber device that is registered to the subscription topic and configured to report the action completion processing based upon the content of the message comprises sending the message to the at least one subscriber device as a two-phase commit transaction; and monitoring the action completion processing based upon the content of the message by the at least one subscriber device comprises receiving an action report message from the at least one subscriber device that comprises a commit status indicating the action completion processing by the at least one subscriber device, where the commit status comprises one of a commit indicator and a rollback indicator.

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

6 . The method of claim 1 , further comprising publishing monitoring results of the monitored action completion 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 callers of an action reporting application programming interface (API), where the callers comprise at least one of the publisher device that published the message and at least one other device.

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

8 . A system, comprising:
a communication module; and a processor of a publish/subscribe message tracking device programmed to:
send, via the communication module, a message associated with a subscription topic hosted 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; and
monitor the action completion processing based upon the content of the message by the at least one subscriber device.

9 . The system of claim 8 , where the processor is further programmed to determine to monitor the action completion processing based upon the content of the message in response to determining that the action completion processing is enabled at the publish/subscribe message tracking device and that the message comprises an indicator requesting the monitoring of the action completion.

10 . The system of claim 8 , where the processor is further programmed to:
configure the message with an instruction to report the action completion processing 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 action completion processing based upon the content of the message by the at least one subscriber device, the processor is programmed to monitor the action completion processing of the message based upon the configured action completion processing report criteria.

11 . The system of claim 8 , where, in being programmed to:
send, via the communication module, the message associated with the subscription topic hosted by the publish/subscribe message tracking device to the at least one subscriber device that is registered to the subscription topic and configured to report the action completion processing based upon the content of the message, the processor is programmed to send the message to the at least one subscriber device as a two-phase commit transaction; and monitor the action completion processing based upon the content of the message by the at least one subscriber device, the processor is programmed to receive, via the communication module, an action report message from the at least one subscriber device that comprises a commit status indicating the action completion processing by the at least one subscriber device, where the commit status comprises one of a commit indicator and a rollback indicator.

12 . The system of claim 8 , where, in being programmed to monitor the action completion processing based upon the content of the message by the at least one subscriber 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 subscriber device that comprises a status of the action completion processing by the at least one subscriber device.

13 . The system of claim 8 , where the processor is further programmed to publish monitoring results of the monitored action completion processing, comprising the processor being programmed to one of:
send, via the communication module, the monitoring results as an action report message t

Assignees

• IBM

Inventors

• Beardsmore Anthony P
• Levell Jonathan

Classifications

• G06F9/542 Primary

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• H04L51/234

  for tracking messages · 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

• H04L41/02

  Standardisation; Integration · CPC title

• H04L43/08

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