Filtering application messages in a high speed, low latency data communications environment

• US 20080244017A1
• Filed: 03/27/2007
• Published: 10/02/2008
• Est. Priority Date: 03/27/2007
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Naaman, Nir, Gershinsky, Gidon, Harpaz, Avraham, Okunseinde, Foluso O., Wright, Cornell G.
• Granted Patent: US 7,917,912 B2
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: H04L 63/0227 Filtering policies mail message filtering H04L51/212
• CPC Class Codes: H04L 67/63 Routing a service request depending on the request content or context

Abstract

Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message; determining, by the transport engine, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label; providing, by the transport engine, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and administering the application message, by the messaging middleware, in dependence upon the collision indicator.

Claims

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

receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message;

determining, by the transport engine of the message receiving device, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label;

providing, by the transport engine of the message receiving device, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and

administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator.

2. The method of claim 1 wherein administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator further comprises:

determining whether a label collision for the application message exists in dependence upon the collision indicator; and

providing the application message to an application of the message receiving device without filtering the application message in the messaging middleware if a label collision for the application message does not exist.

3. The method of claim 1 wherein administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator further comprises:

determining whether a label collision for the application message exists in dependence upon the collision indicator;

determining whether the contents of the application message satisfy a middleware layer constraint if a label collision for the application message exists; and

administering the application message in dependence upon the determination whether the contents of the application message satisfy the middleware layer constraint.

4. The method of claim 1 further comprising:

receiving, in messaging middleware of the message transmitting device from a conversion application of the message transmitting device, the application message for transmission to the message receiving device;

retrieving, by the messaging middleware of the message transmitting device, the contents of the application message;

calculating, by the messaging middleware of the message transmitting device, the message contents label in dependence upon the retrieved contents of the application message;

setting, by the messaging middleware of the message transmitting device, the collision indicator for the application message in dependence upon the message content label and a mapping between contents of application messages and message contents labels; and

transmitting, by a transport engine of the message transmitting device, the application message, the message contents label, and the collision indicator to the message receiving device.

5. The method of claim 4 further comprising:

determining, by the messaging middleware of the message transmitting device, whether a relationship between the contents of the application message and the message contents label is represented in the mapping between contents of application messages and message contents labels; and

adding, by the messaging middleware of the message transmitting device, the relationship between the contents of the application message and the message contents label to the mapping between contents of application messages and message contents labels if the relationship between the contents of the application message and the message contents label is not represented in the mapping.

6. The method of claim 1 further comprising brokering, by a stream administration server, establishment of a message stream from the message transmitting device to the message receiving device, including authenticating the message receiving device, authorizing the message receiving device to receive application messages from the message transmitting device on the message stream, and providing to the transport engine of the message receiving device the transport layer constraint.

7. The method of claim 1 wherein the message receiving device is a subscribing client device and the message transmitting device is a feed adapter.

8. The method of claim 1 wherein the application message further comprises financial market data.

9. The method of claim 1 wherein the message contents label further comprises a message stream identifier.

10. A system for filtering application messages 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 an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message;

determining, by the transport engine of the message receiving device, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label;

providing, by the transport engine of the message receiving device, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and

administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator.

11. The system of claim 10 wherein administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator further comprises:

determining whether a label collision for the application message exists in dependence upon the collision indicator; and

providing the application message to an application of the message receiving device without filtering the application message in the messaging middleware if a label collision for the application message does not exist.

12. The system of claim 10 wherein administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator further comprises:

determining whether a label collision for the application message exists in dependence upon the collision indicator;

determining whether the contents of the application message satisfy a middleware layer constraint if a label collision for the application message exists; and

administering the application message in dependence upon the determination whether the contents of the application message satisfy the middleware layer constraint.

13. The system of claim 10 further comprising computer program instructions capable of:

receiving, in messaging middleware of the message transmitting device from a conversion application of the message transmitting device, the application message for transmission to the message receiving device;

retrieving, by the messaging middleware of the message transmitting device, the contents of the application message;

calculating, by the messaging middleware of the message transmitting device, the message contents label in dependence upon the retrieved contents of the application message;

setting, by the messaging middleware of the message transmitting device, the collision indicator for the application message in dependence upon the message content label and a mapping between contents of application messages and message contents labels; and

transmitting, by a transport engine of the message transmitting device, the application message, the message contents label, and the collision indicator to the message receiving device.

14. The system of claim 10 further comprising computer program instructions capable of brokering, by a stream administration server, establishment of a message stream from the message transmitting device to the message receiving device, including authenticating the message receiving device, authorizing the message receiving device to receive application messages from the message transmitting device on the message stream, and providing to the transport engine of the message receiving device the transport layer constraint.

15. A computer program product for filtering application messages in a high speed, low latency data communications environment, the computer program product disposed upon a recordable medium, the computer program product comprising computer program instructions capable of:

receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message;

determining, by the transport engine of the message receiving device, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label;

providing, by the transport engine of the message receiving device, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and

administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator.

16. The computer program product of claim 15 wherein administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator further comprises:

determining whether a label collision for the application message exists in dependence upon the collision indicator; and

providing the application message to an application of the message receiving device without filtering the application message in the messaging middleware if a label collision for the application message does not exist.

17. The computer program product of claim 15 wherein administering the application message, by the messaging middleware of the message receiving device, in dependence upon the collision indicator further comprises:

determining whether a label collision for the application message exists in dependence upon the collision indicator;

determining whether the contents of the application message satisfy a middleware layer constraint if a label collision for the application message exists; and

administering the application message in dependence upon the determination whether the contents of the application message satisfy the middleware layer constraint.

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

receiving, in messaging middleware of the message transmitting device from a conversion application of the message transmitting device, the application message for transmission to the message receiving device;

retrieving, by the messaging middleware of the message transmitting device, the contents of the application message;

calculating, by the messaging middleware of the message transmitting device, the message contents label in dependence upon the retrieved contents of the application message;

setting, by the messaging middleware of the message transmitting device, the collision indicator for the application message in dependence upon the message content label and a mapping between contents of application messages and message contents labels; and

transmitting, by a transport engine of the message transmitting device, the application message, the message contents label, and the collision indicator to the message receiving device.

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

determining, by the messaging middleware of the message transmitting device, whether a relationship between the contents of the application message and the message contents label is represented in the mapping between contents of application messages and message contents labels; and

adding, by the messaging middleware of the message transmitting device, the relationship between the contents of the application message and the message contents label to the mapping between contents of application messages and message contents labels if the relationship between the contents of the application message and the message contents label is not represented in the mapping.

20. The computer program product of claim 15 further comprising computer program instructions capable of brokering, by a stream administration server, establishment of a message stream from the message transmitting device to the message receiving device, including authenticating the message receiving device, authorizing the message receiving device to receive application messages from the message transmitting device on the message stream, and providing to the transport engine of the message receiving device the transport layer constraint.