SUBSCRIBER MESSAGE PAYLOAD HANDLING

• US 20120233272A1
• Filed: 02/28/2012
• Published: 09/13/2012
• Est. Priority Date: 03/11/2011
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bedi, Barat V., Bowyer, Helen S., Brown, Kevin C., Jellard, Edward G., Smart, Robert S., White, Graham
• Granted Patent: US 8,799,469 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• 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 configured to identify and extract the payload data and store the payload data 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, with the second computer handler being configured to identify and extract the function data and store the function data in the memory;

a generator configured to modify the extracted and stored payload data according to the stored function; and

an inserter configured to insert the modified payload data into a third message for distribution to a subscriber configured 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 configured 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 configured 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 configured 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 configured 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 configured to, in response to receipt of a predetermined command, delete the stored function data.

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

7. A 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;

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

identifying the function data within the received second message;

extracting and storing the function data;

using the stored function to modify the extracted and stored payload data; and

creating a third message comprising the modified payload data for distribution to a subscriber configured to process the modified payload in the third message.

8. The 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, stored function data to use to modify the payload data.

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

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

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

12. The 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 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 method of claim 7, where the first publisher is also the second publisher.

15. A computer program product comprising a computer readable storage medium 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;

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;

identify the function data within the received second message;

extract and store the function data;

use the stored function to modify the extracted and stored payload data; and

create a third message comprising the modified payload data for distribution to a subscriber configured to process the modified payload 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, stored function data to use to modify the payload data.

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.