COMPUTER DATA COMMUNICATIONS IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT

• US 20070300233A1
• Filed: 06/27/2006
• Published: 12/27/2007
• Est. Priority Date: 06/27/2006
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Lewis, Paul D., Okunseinde, Foluso O., Ravisankar, Ramanujam, Wright, Cornell G., BHOGAL, KULVIR S
• Granted Patent: US 8,296,778 B2
• Time in Patent Office: Days
• US Class Current: 719/313
• CPC Class Codes: G06F 2209/547 Messaging middleware
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: H04L 63/08 for authentication of entities cryptographic mechanisms or cryptographic arrangements for entity authentication H04L9/32

Abstract

Methods, apparatus, and products are disclosed for computer data communications in a high speed, low latency data communications environment that include: brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter; receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware, whether contents of the message satisfy the constraints; and administering the message, by the messaging middleware, in dependence upon whether the message satisfies the constraints.

Claims

1. A method of computer data communications in a high speed, low latency data communications environment, the method comprising:

brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter;

receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream;

determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the constraints; and

administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the constraints.

2. The method of claim 1 wherein the high speed, low latency data communications environment comprises a high speed, low latency data communications network, the network further comprising the feed adapter, the stream administration server, at least one subscribing client device, the contributing client device, and no router.

3. The method of claim 1 wherein the feed adapter comprises a device having the capabilities of converting messages on a feed adapter input stream having a first format to messages on a feed adapter output stream having a second format and multicasting the messages on the feed adapter output stream to subscribing client devices.

4. The method of claim 1 wherein administering the message further comprises authorizing transmission of the message on the stream in dependence upon whether the message satisfies the constraints.

5. The method of claim 1 wherein administering the message further comprises logging the message in dependence upon whether the message satisfies the constraints.

6. The method of claim 1 further comprising setting, by the stream administration server, values of constraints in the messaging middleware of the contributing client device that prevent the message from being sent on the message stream.

7. The method of claim 1 wherein:

each constraint is characterized by a message field identifier, a constraint value, and a constraint operator; and

determining, by the messaging middleware, whether contents of the message satisfy the constraints further comprises applying the constraint operator to the constraint value and to a value from a data field in the message identified by the message field identifier.

8. Apparatus for computer data communications in a high speed, low latency data communications environment, the apparatus comprising one or more computer processors, one or more computer memories operatively coupled to the one or more computer processors, the computer memories having disposed within them computer program instructions capable of:

brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter;

receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream;

determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the constraints; and

administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the constraints.

9. The apparatus of claim 8 wherein the high speed, low latency data communications environment comprises a high speed, low latency data communications network, the network further comprising the feed adapter, the stream administration server, at least one subscribing client device, the contributing client device, and no router.

10. The apparatus of claim 8 wherein the feed adapter comprises a device having the capabilities of converting messages on a feed adapter input stream having a first format to messages on a feed adapter output stream having a second format and multicasting the messages on the feed adapter output stream to subscribing client devices.

11. The apparatus of claim 8 wherein administering the message further comprises authorizing transmission of the message on the stream in dependence upon whether the message satisfies the constraints.

12. The apparatus of claim 8 wherein administering the message further comprises logging the message in dependence upon whether the message satisfies the constraints.

13. The apparatus of claim 8 wherein:

each constraint is characterized by a message field identifier, a constraint value, and a constraint operator; and

determining, by the messaging middleware, whether contents of the message satisfy the constraints further comprises applying the constraint operator to the constraint value and to a value from a data field in the message identified by the message field identifier.

14. A computer program product for computer data communications in a high speed, low latency data communications environment, the computer program product disposed upon a signal bearing medium, the computer program product comprising computer program instructions capable of:

brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter;

receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream;

determining, by the messaging middleware of the contributing client device, whether contents of the message satisfy the constraints; and

administering the message, by the messaging middleware of the contributing client device, in dependence upon whether the message satisfies the constraints.

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

16. The computer program product of claim 14 wherein the signal bearing medium comprises a transmission medium.

17. The computer program product of claim 14 wherein the high speed, low latency data communications environment comprises a high speed, low latency data communications network, the network further comprising the feed adapter, the stream administration server, at least one subscribing client device, the contributing client device, and no router.

18. The computer program product of claim 14 wherein administering the message further comprises authorizing transmission of the message on the stream in dependence upon whether the message satisfies the constraints.

19. The computer program product of claim 14 wherein administering the message further comprises logging the message in dependence upon whether the message satisfies the constraints.

20. The computer program product of claim 14 wherein:

each constraint is characterized by a message field identifier, a constraint value, and a constraint operator; and

determining, by the messaging middleware, whether contents of the message satisfy the constraints further comprises applying the constraint operator to the constraint value and to a value from a data field in the message identified by the message field identifier.