Subscribing For Application Messages In A Multicast Messaging Environment

• US 20080141274A1
• Filed: 12/12/2006
• Published: 06/12/2008
• Est. Priority Date: 12/12/2006
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bhogal, Kulvir S., Lewis, Paul D., Ravisankar, Ramanujam, Wang, John J., Borgendale, Kenneth W.
• Granted Patent: US 8,850,451 B2
• Time in Patent Office: Days
• US Class Current: 719/313
• CPC Class Codes: G06F 2209/547 Messaging middleware
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]

Abstract

Methods, systems, and products for subscribing for application messages in a multicast messaging environment as disclosed that include: requesting, by a message receiving device, a stream administration server to initialize a message subscription for application messages from a message sending device; receiving, in the message receiving device from the stream administration server, a data communications endpoint of a multicast message stream from the message sending device; beginning to listen, by the message receiving device, for the application messages at the data communications endpoint; and notifying, by the message receiving device after beginning to listen for the application messages, the message sending device to publish the application messages at the data communications endpoint.

Claims

1. A method of subscribing for application messages in a multicast messaging environment, the method comprising:

requesting, by a message receiving device, a stream administration server to initialize a message subscription for application messages from a message sending device;

receiving, in the message receiving device from the stream administration server, a data communications endpoint of a multicast message stream from the message sending device;

beginning to listen, by the message receiving device, for the application messages at the data communications endpoint; and

notifying, by the message receiving device after beginning to listen for the application messages, the message sending device to publish the application messages at the data communications endpoint.

2. The method of claim 1 wherein receiving a data communications endpoint further comprises receiving, in addition to the data communications endpoint, one or more alternate data communications endpoints, and the method further comprises:

identifying, by the message receiving device, a failure condition for the data communication endpoint;

switching, by the message receiving device in response to the failure condition, from listening for the application messages at the data communication endpoint to listening for the application messages at one of the alternate data communication endpoints.

3. The method of claim 1 further comprising:

receiving, in the message sending device, a notification to publish the application messages; and

increasing, by the message sending device in response to receiving the notification to publish the application messages, a value for a computer data element representing subscriber interest in the application messages.

4. The method of claim 1 further comprising notifying, by the message receiving device, the message sending device to stop publishing the application messages at the data communications endpoint.

5. The method of claim 1 further comprising:

receiving, in the message sending device, a notification to stop publishing the application messages;

decreasing, by the message sending device in response to receiving the notification to stop publishing the application messages, a value for a computer data element representing subscriber interest in the application messages;

determining, by the message sending device, whether the value for a computer data element representing subscriber interest in the application messages is below a predetermined threshold; and

notifying, by the message sending device, a data provider to stop providing the application message to the message sending device if the value for a computer data element representing subscriber interest in the application messages is below the predetermined threshold.

6. The method of claim 1 further comprising requesting, by the message receiving device, the stream administration server to close the message subscription.

7. The method of claim 1 wherein the application messages comprise financial market data.

8. A system for subscribing for application messages in a multicast messaging environment, the system comprising one or more computer processors, computer memory operatively coupled to the one or more computer processors, the computer memory having disposed within it computer program instructions capable of:

requesting, by a message receiving device, a stream administration server to initialize a message subscription for application messages from a message sending device;

receiving, in the message receiving device from the stream administration server, a data communications endpoint of a multicast message stream from the message sending device;

beginning to listen, by the message receiving device, for the application messages at the data communications endpoint; and

notifying, by the message receiving device after beginning to listen for the application messages, the message sending device to publish the application messages at the data communications endpoint.

9. The system of claim 8 further comprising computer program instructions capable of:

receiving, in the message sending device, a notification to publish the application messages; and

increasing, by the message sending device in response to receiving the notification to publish the application messages, a value for a computer data element representing subscriber interest in the application messages.

10. The system of claim 8 further comprising computer program instructions capable of notifying, by the message receiving device, the message sending device to stop publishing the application messages at the data communications endpoint.

11. The system of claim 8 further comprising computer program instructions capable of:

receiving, in the message sending device, a notification to stop publishing the application messages;

decreasing, by the message sending device in response to receiving the notification to stop publishing the application messages, a value for a computer data element representing subscriber interest in the application messages;

determining, by the message sending device, whether the value for a computer data element representing subscriber interest in the application messages is below a predetermined threshold; and

notifying, by the message sending device, a data provider to stop providing the application message to the message sending device if the value for a computer data element representing subscriber interest in the application messages is below the predetermined threshold.

12. The system of claim 8 further comprising computer program instructions capable of requesting, by the message receiving device, the stream administration server to close the message subscription.

13. A computer program product for subscribing for application messages in a multicast messaging environment, the computer program product disposed upon a signal bearing medium, the computer program product comprising computer program instructions capable of:

requesting, by a message receiving device, a stream administration server to initialize a message subscription for application messages from a message sending device;

receiving, in the message receiving device from the stream administration server, a data communications endpoint of a multicast message stream from the message sending device;

beginning to listen, by the message receiving device, for the application messages at the data communications endpoint; and

notifying, by the message receiving device after beginning to listen for the application messages, the message sending device to publish the application messages at the data communications endpoint.

14. The computer program product of claim 13 wherein the signal bearing medium comprises a recordable medium.

15. The computer program product of claim 13 wherein the signal bearing medium comprises a transmission medium.

16. The computer program product of claim 13 wherein receiving a data communications endpoint further comprises receiving, in addition to the data communications endpoint, one or more alternate data communications endpoints, and the computer program product further comprises computer program instructions capable of:

identifying, by the message receiving device, a failure condition for the data communication endpoint;

switching, by the message receiving device in response to the failure condition, from listening for the application messages at the data communication endpoint to listening for the application messages at one of the alternate data communication endpoints.

17. The computer program product of claim 13 further comprising computer program instructions capable of:

receiving, in the message sending device, a notification to publish the application messages; and

increasing, by the message sending device in response to receiving the notification to publish the application messages, a value for a computer data element representing subscriber interest in the application messages.

18. The computer program product of claim 13 further comprising computer program instructions capable of notifying, by the message receiving device, the message sending device to stop publishing the application messages at the data communications endpoint.

19. The computer program product of claim 13 further comprising computer program instructions capable of:

receiving, in the message sending device, a notification to stop publishing the application messages;

decreasing, by the message sending device in response to receiving the notification to stop publishing the application messages, a value for a computer data element representing subscriber interest in the application messages;

determining, by the message sending device, whether the value for a computer data element representing subscriber interest in the application messages is below a predetermined threshold; and

notifying, by the message sending device, a data provider to stop providing the application message to the message sending device if the value for a computer data element representing subscriber interest in the application messages is below the predetermined threshold.

20. The computer program product of claim 13 further comprising computer program instructions capable of requesting, by the message receiving device, the stream administration server to close the message subscription.