Subscribing for application messages in a multicast messaging environment

• US 8,850,451 B2
• Filed: 12/12/2006
• Issued: 09/30/2014
• Est. Priority Date: 12/12/2006
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bhogal, Kulvir S., Borgendale, Kenneth W., Lewis, Paul D., Ravisankar, Ramanujam, Wang, John J.
• Primary Examiner(s): DAO, TUAN C.
• Application Number:
  US11/609,604
• Publication Number:
  US 20080141274A1
• Time in Patent Office: 2,849 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 related to a topic from a message sending device, wherein said requesting comprises transmitting to the stream administration server a request that indicates the topic and security credentials of the message receiving device for the stream administration server to authenticate and authorize the message receiving device;

receiving, in the message receiving device from the stream administration server, a data communications endpoint that at least indicates a multicast network address for 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

transmitting, by the message receiving device only after beginning to listen for the application messages related to the topic, to the stream administration server a notification that notifies the message sending device to publish the application messages to the multicast network address.

2. The method of claim 1 further comprising:

receiving, in addition to the data communications endpoint, one or more alternate data communications endpoints,

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

switching, by the message receiving device in response to the failure condition, from listening for the application messages at the data communications endpoint to listening for the application messages at one of the alternate data communications 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 executable by the one or more computer processors to cause the system to perform operations comprising:

requesting, a stream administration server to initialize a message subscription for application messages related to a topic from a message sending device, wherein said requesting comprises transmitting to the stream administration server a request that indicates the topic and security credentials of a message recipient for the stream administration server to authenticate and authorize the message recipient;

receiving, from the stream administration server, a data communications endpoint that at least indicates a multicast network address for a multicast message stream from the message sending device;

beginning to listen for the application messages at the data communications endpoint; and

transmitting, only after beginning to listen for the application messages related to the topic, to the stream administration server a notification that notifies the message sending device to publish the application messages to the multicast network address.

9. The system of claim 8 further comprising computer program instructions executable by the one or more processors to cause the system to perform operations 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.

10. The system of claim 8 further comprising computer program instructions executable by the one or more processors to cause the system to perform operations comprising notifying 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 executable by the one or more processors to cause the system to perform operations 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.

12. The system of claim 8 further comprising computer program instructions executable by the one or more processors to cause the system to perform operations comprising requesting the stream administration server to close the message subscription.

13. A computer program product for subscribing to application messages in a multicast messaging environment, the computer program product disposed upon a recordable medium, the computer program product comprising computer program instructions to:

request a stream administration server to initialize a message subscription for application messages related to a topic from a message sending device, wherein the computer program instructions to request the stream administration server to initialize a message subscription for application messages related to a topic comprises computer program instructions to transmit to the stream administration server a request that indicates the topic and security credentials of a message recipient for the stream administration server to authenticate and authorize the message recipient;

receive from the stream administration server, a data communications endpoint that at least indicates a multicast network address for a multicast message stream from the message sending device;

begin to listen, for the application messages at the data communications endpoint; and

transmit, only after beginning to listen for the application messages related to the topic, to the stream administration server a notification that notifies the message sending device to publish the application messages to the multicast network address.

14. The computer program product of claim 13 wherein the computer program instructions further comprise computer program instructions to:

receive, in addition to the data communications endpoint, one or more alternate data communications endpoints;

identify a failure condition for the data communications endpoint;

switch, in response to the failure condition, from listening for the application messages at the data communications endpoint to listening for the application messages at one of the alternate data communications endpoints.

15. The computer program product of claim 13 further comprising computer program instructions to:

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

increase, 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.

16. The computer program product of claim 13 further comprising computer program instructions to notify the message sending device to stop publishing the application messages at the data communications endpoint.

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

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

decrease, 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;

determine, 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

notify, 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.

18. The computer program product of claim 13 further comprising computer program instructions to request the stream administration server to close the message subscription.