Subscriber message payload handling

• US 8,799,469 B2
• Filed: 02/28/2012
• Issued: 08/05/2014
• Est. Priority Date: 03/11/2011
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bowyer, Helen S., Brown, Kevin C., Jellard, Edward G., Smart, Robert S., White, Graham, Bedi, Bharat V.
• Primary Examiner(s): LIN, WEN TAI
• Application Number:
  US13/407,199
• Publication Number:
  US 20120233272A1
• Time in Patent Office: 889 Days
• Field of Search: None
• US Class Current: 709/225
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A first message published by a first publisher, including a message header and payload data, is received. The payload data within the first received message is identified, extracted, and stored. A second message published by a second publisher, including function data that provides a function to modify the payload data, is received. The function data within the second received message is identified, extracted, and stored. The extracted and stored payload data is modified using the stored function. A third message, including the modified payload data, is created for distribution to a subscriber configured to process the modified payload in the third message.

Claims

1. An apparatus for modified payload data handling in a publish/subscribe system, comprising:

a processor;

a memory coupled with the processor;

a first computer handler for handling a received first message published by a first publisher, the first message comprising a message header and payload data, with the first computer handler being programmed to identify and extract the payload data and store the payload data of the received first message in the memory;

a second computer handler for handling a received second message published by a second publisher, the second message comprising function data that provides a function to modify the payload data of the received first message, with the second computer handler being programmed to identify and extract the function data and store the function data of the received second message in the memory;

a generator programmed to modify the extracted and stored payload data of the received first message according to the function of the stored function data of the received second message; and

an inserter programmed to insert the modified payload data of the received first message into a third message for distribution to a subscriber programmed to process the modified payload data in the third message.

2. The apparatus of claim 1, where the first and second computer handlers comprise a single device programmed to distinguish between the received first message and the received second message.

3. The apparatus of claim 1, where the message header of the received first message comprises topic data, the memory contains a topic tree used in distribution of messages to subscribers according to topic, and the second computer handler is programmed to store the extracted function data in a predetermined location within the topic tree.

4. The apparatus of claim 1, where the second computer handler is further programmed to receive and process a plurality of second messages and store respective sets of function data received via the plurality of second messages, and the generator is further programmed to identify which, if any, set of stored function data to use in the modification of the payload data of the received first message.

5. The apparatus of claim 1, where the second computer handler is further programmed to, in response to receipt of a predetermined command, verify a source of the predetermined command as a precondition of deleting the stored function data, and delete the stored function data.

6. The apparatus of claim 1, where the second computer handler is further programmed to, in response to receipt of a predetermined command, modify the stored function data.

7. A computer-implemented method for modified payload data handling in a publish/subscribe system, comprising:

receiving a first message published by a first publisher, the first message comprising a message header and payload data;

identifying the payload data within the received first message;

extracting and storing the payload data of the received first message;

receiving a second message published by a second publisher, the second message comprising function data that provides a function to modify the payload data of the received first message;

identifying the function data within the received second message;

extracting and storing the function data of the received second message;

using the function of the stored function data of the received second message to modify the extracted and stored payload data of the received first message; and

creating a third message comprising the modified payload data of the received first message for distribution to a subscriber programmed to process the modified payload data in the third message.

8. The computer-implemented method of claim 7, further comprising receiving a plurality of second messages, extracting and storing respective sets of function data received via the plurality of second messages, and determining for the received first message which, if any, set of stored function data to use to modify the payload data of the received first message.

9. The computer-implemented method of claim 7, where the subscriber is also the second publisher.

10. The computer-implemented method of claim 9, where there are a plurality of subscribers, at least one of which subscribes to the received modified payload data modified by the function, and the second message comprising the function data that provides the function is originated by another subscriber.

11. The computer-implemented method of claim 7, further comprising, in response to receipt of a predetermined command, deleting the stored function data.

12. The computer-implemented method of claim 11, further comprising, in response to receipt of the predetermined command, verifying a source of the predetermined command as a precondition of deleting the stored function data.

13. The computer-implemented method of claim 7, where the first publisher comprises a plurality of first publishers publishing messages to respective topics and a plurality of subscribers each receiving messages on one or more of the topics and, further in response to receipt of a predetermined command, applying one of a plurality of sets of stored function data to modify payload data of all messages published to an identified topic.

14. The computer-implemented method of claim 7, where the first publisher is also the second publisher.

15. A computer program product comprising a computer readable storage device including computer readable program code, where the computer readable program code when executed on a computer causes the computer to:

receive a first message published by a first publisher, the received first message comprising a message header and payload data;

identify the payload data within the received first message;

extract and store the payload data of the received first message;

receive a second message published by a second publisher, the received second message comprising function data that provides a function to modify the payload data of the received first message;

identify the function data within the received second message;

extract and store the function data of the received second message;

use the function of the stored function data of the received second message to modify the extracted and stored payload data of the received first message; and

create a third message comprising the modified payload data of the received first message for distribution to a subscriber programmed to process the modified payload data in the third message.

16. The computer program product of claim 15, where the computer readable program code when executed on the computer further causes the computer to receive a plurality of second messages, extract and store respective sets of function data received via the plurality of second messages, and determine for the received first message which, if any, set of stored function data to use to modify the payload data of the received first message.

17. The computer program product of claim 15, where the computer readable program code when executed on the computer further causes the computer to, in response to receipt of a predetermined command, delete the stored function data.

18. The computer program product of claim 17, where the computer readable program code when executed on the computer further causes the computer to, in response to receipt of the predetermined command, verify a source of the predetermined command as a precondition of deleting the stored function data.

19. The computer program product of claim 15, where the first publisher comprises a plurality of first publishers publishing messages to respective topics and a plurality of subscribers each receiving messages on one or more of the topics, and where the computer readable program code when executed on the computer further causes the computer to, in response to receipt of a predetermined command, apply one of a plurality of sets of stored function data to modify payload data of all messages published to an identified topic.

20. The computer program product of claim 15, where the first publisher is also the second publisher.