Application Message Subscription Tracking In A High Speed, Low Latency Data Communications Environment

• US 20090006559A1
• Filed: 06/27/2007
• Published: 01/01/2009
• Est. Priority Date: 06/27/2007
• Status: Abandoned Application

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Duigenan, John J., Kang, Kwang S., Ravisankar, Ravi, Wang, John J., Bhogal, Kulvir S., Lewis, Paul D.
• Application Number:
  US11/769,240
• Publication Number:
  US 20090006559A1
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: G06Q 10/107 Computer-aided management of electronic mailing [e-mailing]
• CPC Class Codes: H04L 12/1818 Conference organisation arrangements, e.g. handling schedules, setting up parameters needed by nodes to attend a conference, booking network resources, notifying involved parties

Abstract

Methods, systems, and products are disclosed for application message subscription tracking in a high speed, low latency data communications environment that includes: receiving, by a stream administration server from a subscribing client device, a subscription initiation request, the subscription initiation request specifying a message topic, the message topic specifying application messages for transmission to the subscribing client device from a message transmitting device; brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device; and updating, by the stream administration server, a client subscription repository for monitoring application message subscriptions in dependence upon the subscription initiation request.

Claims

1. A method of application message subscription tracking in a high speed, low latency data communications environment, the method comprising:

receiving, by a stream administration server from a subscribing client device, a subscription initiation request, the subscription initiation request specifying a message topic, the message topic specifying application messages for transmission to the subscribing client device from a message transmitting device;

brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device; and

updating, by the stream administration server, a client subscription repository for monitoring application message subscriptions in dependence upon the subscription initiation request.

2. The method of claim 1 further comprising:

receiving, by the stream administration server from the subscribing client device, a subscription termination request that specifies the message topic; and

updating, by the stream administration server, the client subscription repository in dependence upon the subscription termination request.

3. The method of claim 1 further comprising:

polling, by the stream administration server, the subscribing client device for message topics subscribed to by the subscribing client device; and

updating, by the stream administration server, the client subscription repository in dependence upon the polled message topics.

4. The method of claim 1 further comprising:

receiving, in the stream administration server from a subscription monitor, a request for message topics subscribed to by the subscribing client device;

retrieving, by the stream administration server, results of the request from the client subscription repository; and

returning, by the stream administration server, the results to the subscription monitor.

5. The method of claim 1 wherein brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device further comprises:

authenticating the subscribing client device;

authorizing the subscribing client device to receive application messages for the message topic specified in the subscription initiation request; and

providing the subscribing client device with a data communications endpoint of the message stream for receiving the application messages for the message topic.

6. The method of claim 1 wherein:

the stream administration server, the subscribing client device, and the message transmitting device are connected for data communications using a high speed, low latency data communications network; and

the message transmitting device is a feed adapter capable of converting application messages received on a feed adapter input stream having a first format to application messages having a second format for transmission on a feed adapter output stream to subscribing client devices.

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

8. A system for application message subscription tracking in a high speed, low latency data communications 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:

receiving, by a stream administration server from a subscribing client device, a subscription initiation request, the subscription initiation request specifying a message topic, the message topic specifying application messages for transmission to the subscribing client device from a message transmitting device;

brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device; and

updating, by the stream administration server, a client subscription repository for monitoring application message subscriptions in dependence upon the subscription initiation request.

9. The system of claim 8 wherein the computer memory also has disposed within it computer program instructions capable of:

receiving, by the stream administration server from the subscribing client device, a subscription termination request that specifies the message topic; and

updating, by the stream administration server, the client subscription repository in dependence upon the subscription termination request.

10. The system of claim 8 wherein the computer memory also has disposed within it computer program instructions capable of:

polling, by the stream administration server, the subscribing client device for message topics subscribed to by the subscribing client device; and

updating, by the stream administration server, the client subscription repository in dependence upon the polled message topics.

11. The system of claim 8 wherein the computer memory also has disposed within it computer program instructions capable of:

receiving, in the stream administration server from a subscription monitor, a request for message topics subscribed to by the subscribing client device;

retrieving, by the stream administration server, results of the request from the client subscription repository; and

returning, by the stream administration server, the results to the subscription monitor.

12. The system of claim 8 wherein brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device further comprises:

authenticating the subscribing client device;

authorizing the subscribing client device to receive application messages for the message topic specified in the subscription initiation request; and

providing the subscribing client device with a data communications endpoint of the message stream for receiving the application messages for the message topic.

13. The system of claim 8 wherein:

the stream administration server, the subscribing client device, and the message transmitting device are connected for data communications using a high speed, low latency data communications network; and

the message transmitting device is a feed adapter capable of converting application messages received on a feed adapter input stream having a first format to application messages having a second format for transmission on a feed adapter output stream to subscribing client devices.

14. A computer program product for application message subscription tracking in a high speed, low latency data communications environment, the computer program product disposed upon a computer readable medium, the computer program product comprising computer program instructions capable of:

receiving, by a stream administration server from a subscribing client device, a subscription initiation request, the subscription initiation request specifying a message topic, the message topic specifying application messages for transmission to the subscribing client device from a message transmitting device;

brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device; and

updating, by the stream administration server, a client subscription repository for monitoring application message subscriptions in dependence upon the subscription initiation request.

15. The computer program product of claim 14 further comprising computer program instructions capable of:

receiving, by the stream administration server from the subscribing client device, a subscription termination request that specifies the message topic; and

updating, by the stream administration server, the client subscription repository in dependence upon the subscription termination request.

16. The computer program product of claim 14 further comprising computer program instructions capable of:

polling, by the stream administration server, the subscribing client device for message topics subscribed to by the subscribing client device; and

updating, by the stream administration server, the client subscription repository in dependence upon the polled message topics.

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

receiving, in the stream administration server from a subscription monitor, a request for message topics subscribed to by the subscribing client device;

retrieving, by the stream administration server, results of the request from the client subscription repository; and

returning, by the stream administration server, the results to the subscription monitor.

18. The computer program product of claim 14 wherein brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device further comprises:

authenticating the subscribing client device;

authorizing the subscribing client device to receive application messages for the message topic specified in the subscription initiation request; and

providing the subscribing client device with a data communications endpoint of the message stream for receiving the application messages for the message topic.

19. The computer program product of claim 14 wherein:

the stream administration server, the subscribing client device, and the message transmitting device are connected for data communications using a high speed, low latency data communications network; and

the message transmitting device is a feed adapter capable of converting application messages received on a feed adapter input stream having a first format to application messages having a second format for transmission on a feed adapter output stream to subscribing client devices.

20. The computer program product of claim 14 wherein the application messages comprises financial market data.