Message delivery in a message system

• US 10,257,142 B2
• Filed: 08/13/2018
• Issued: 04/09/2019
• Est. Priority Date: 02/22/2016
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Baldwin, Timothy J., Johnson, Andrew, Johnson, Peter J., Xu, Fenglian
• Primary Examiner(s): Chea, Philip J
• Assistant Examiner(s): Khan, Hassan A
• Application Number:
  US16/102,222
• Publication Number:
  US 20190014066A1
• Time in Patent Office: 239 Days
• Field of Search: None
• CPC Class Codes: H04L 51/212 using filtering or selective blocking
• CPC Class Codes: H04L 67/55 Push-based network services
• CPC Class Codes: H04L 67/562 Brokering proxy services

Abstract

Control of message delivery from publisher devices to a subscriber application of a messaging system is provided. The subscriber application has a subscription registered with a broker application of the messaging system and is only permitted to receive messages relating to a topic of the subscription from a predetermined set of one or more publisher devices. The method includes: altering a topic identifier of a message from a publisher device to a modified topic identifier, and altering a subscription identifier from a subscriber application to a modified subscription identifier; analyzing the modified topic identifier and the modified subscription identifier to determine if the message is to be communicated to the subscriber application, and if so, information is removed from the modified topic identifier to form a reverted topic identifier, and the message and reverted topic identifier are communicated to the subscriber application.

Claims

1. A computer-implemented method of controlling message delivery from publisher devices to a subscriber application of a messaging system, the subscriber application having a subscription registered with a message broker of the messaging system and only being permitted to receive messages relating to a topic of the subscription from a predetermined set of one or more publisher devices, the method comprising:

receiving a message from a publisher device and, based on receiving the message, altering a topic identifier of the message to a modified topic identifier comprising a description of the topic of the message and a set of one or more publisher devices that the publisher device belongs to, and providing the message with the modified topic identifier to the message broker;

receiving a subscription identifier from a subscriber application and, based on receiving the subscription identifier, altering the subscription identifier to a modified subscription identifier comprising a description of the topic of the subscription and a predetermined set of one or more publisher devices from which the subscriber application is permitted to receive messages, and providing the modified subscription identifier to the message broker;

analyzing the modified topic identifier and the modified subscription identifier, and determining whether the message is to be communicated to the subscriber application; and

based on determining that the message is to be communicated to the subscriber application, removing from the modified topic identifier the description of the set of one or more publisher devices that the publisher device belongs to, wherein the removing forms a reverted topic identifier of the message, and sending the message and reverted topic identifier to the subscriber application.

2. The computer-implemented method of claim 1, wherein the removing the description of the set of one or more publisher devices that the publisher device belongs to from the modified topic identifier is undertaken such that the reverted topic identifier is identical to the topic identifier of the message from the publisher device.

3. The computer-implemented method of claim 1, wherein at least one of the altering the topic identifier or the altering the subscription identifier is undertaken by a proxy application adapted to intercept at least one of messages or subscription identifiers being communicated to or from the message broker.

4. The computer-implemented method of claim 1, wherein the description of the topic of the subscription comprises a string supporting wildcard entries, and wherein the description of the topic of the message comprises a string.

5. The computer-implemented method of claim 4, wherein the message broker is a Message Queuing Telemetry Transport, MQTT, broker application.

6. The computer-implemented method of claim 1, further comprising:

obtaining a data structure describing a plurality of different sets of one more publisher devices; and

wherein the altering the topic identifier comprises analyzing the obtained data structure to identify the set of one or more publisher devices that the publisher device belongs to.

7. The computer-implemented method of claim 6, wherein the altering the subscription identifier comprises analyzing the obtained data structure to identify the set of one or more publisher devices that a message is permitted to be received from.

8. A computer program product for controlling message delivery from publisher devices to a subscriber application of a messaging system, the subscriber application having a subscription registered with a message broker of the messaging system and only being permitted to receive messages relating to a topic of the subscription from a predetermined set of one or more publisher devices, the computer program product comprising:

a non-transitory computer readable storage medium having program instructions embodied therewith, the program instructions executable by a processing unit to cause the processing unit to perform a method comprising;

receiving a message from a publisher device and, based on receiving the message, altering a topic identifier of the message to a modified topic identifier comprising a description of the topic of the message and a set of one or more publisher devices that the publisher device belongs to, and providing the message with the modified topic identifier to the message broker;

receiving a subscription identifier from a subscriber application and, based on receiving the subscription identifier, altering the subscription identifier to a modified subscription identifier comprising a description of the topic of the subscription and a predetermined set of one or more publisher devices from which the subscriber application is permitted to receive messages, and providing the modified subscription identifier to the message broker;

analyzing the modified topic identifier and the modified subscription identifier, and determining whether the message is to be communicated to the subscriber application; and

based on determining that the message is to be communicated to the subscriber application, removing from the modified topic identifier the description of the set of one or more publisher devices that the publisher device belongs to, wherein the removing forms a reverted topic identifier of the message, and sending the message and reverted topic identifier to the subscriber application.

9. The computer program product of claim 8, wherein the removing the description of the set of one or more publisher devices that the publisher device belongs to from the modified topic identifier is undertaken such that the reverted topic identifier is identical to the topic identifier of the message from the publisher device.

10. The computer program product of claim 8, wherein at least one of the altering the topic identifier or the altering the subscription identifier is undertaken by a proxy application adapted to intercept at least one of messages or subscription identifiers being communicated to or from the message broker.

11. The computer program product of claim 8, wherein the description of the topic of the subscription comprises a string supporting wildcard entries, and wherein the description of the topic of the message comprises a string.

12. The computer program product of claim 11, wherein the message broker is a Message Queuing Telemetry Transport, MQTT, broker application.

13. The computer program product of claim 8, further comprising:

obtaining a data structure describing a plurality of different sets of one more publisher devices; and

wherein the altering the topic identifier comprises analyzing the obtained data structure to identify the set of one or more publisher devices that the publisher device belongs to.

14. The computer program product of claim 13, wherein the altering the subscription identifier comprises analyzing the obtained data structure to identify the set of one or more publisher devices that a message is permitted to be received from.

15. A system for controlling message delivery from publisher devices to a subscriber application of a messaging system, the subscriber application having a subscription registered with a message broker of the messaging system and only being permitted to receive messages relating to a topic of the subscription from a predetermined set of one or more publisher devices, the system comprising:

a memory; and

a processor communicatively coupled to the memory, wherein the system performs a method comprising;

receiving a message from a publisher device and, based on receiving the message, altering a topic identifier of the message to a modified topic identifier comprising a description of the topic of the message and a set of one or more publisher devices that the publisher device belongs to, and providing the message with the modified topic identifier to the message broker;

receiving a subscription identifier from a subscriber application and, based on receiving the subscription identifier, altering the subscription identifier to a modified subscription identifier comprising a description of the topic of the subscription and a predetermined set of one or more publisher devices from which the subscriber application is permitted to receive messages, and providing the modified subscription identifier to the message broker;

analyzing the modified topic identifier and the modified subscription identifier, and determining whether the message is to be communicated to the subscriber application; and

based on determining that the message is to be communicated to the subscriber application, removing from the modified topic identifier the description of the set of one or more publisher devices that the publisher device belongs to, wherein the removing forms a reverted topic identifier of the message, and sending the message and reverted topic identifier to the subscriber application.

16. The system of claim 15, wherein the removing the description of the set of one or more publisher devices that the publisher device belongs to from the modified topic identifier is undertaken such that the reverted topic identifier is identical to the topic identifier of the message from the publisher device.

17. The system of claim 15, wherein at least one of the altering the topic identifier or the altering the subscription identifier is undertaken by a proxy application adapted to intercept at least one of messages or subscription identifiers being communicated to or from the message broker.

18. The system of claim 15, wherein the description of the topic of the subscription comprises a string supporting wildcard entries, and wherein the description of the topic of the message comprises a string.

19. The system of claim 18, wherein the message broker is a Message Queuing Telemetry Transport, MQTT, broker application.

20. The system of claim 15, wherein the method further comprises:

obtaining a data structure describing a plurality of different sets of one more publisher devices; and

wherein the altering the topic identifier comprises analyzing the obtained data structure to identify the set of one or more publisher devices that the publisher device belongs to.