SELECTING APPLICATION MESSAGES FROM AN ACTIVE FEED ADAPTER AND A BACKUP FEED ADAPTER FOR APPLICATION-LEVEL DATA PROCESSING IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
First Claim
1. A method of selecting application messages from an active feed adapter and a backup feed adapter for application-level data processing in a high speed, low latency data communications environment, the method comprising:
- brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter, the active message stream comprising active application messages;
brokering, by the stream administration server, establishment of a backup message stream to the subscribing client device from a backup feed adapter, the backup message stream comprising backup application messages representing duplicates of the active application messages;
receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter, each active transport packet including one or more active application messages, each active transport packet characterized by an active packet sequence number, the active application messages from the active transport packets used for further data processing by an application of the subscribing client device;
receiving and buffering backup transport packets in the transport engine of the subscribing client device from the backup feed adapter, each backup transport packet including one or more backup application messages, each backup transport packet characterized by a backup packet sequence number and representing a duplicate of a corresponding active transport packet;
identifying, by the transport engine in dependence upon the active packet sequence numbers, a missing active transport packet;
determining, by the transport engine, whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and
replacing, by the transport engine, the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received from the backup feed adapter.
1 Assignment
0 Petitions
Accused Products
Abstract
Selecting application messages from redundant feed adapters for application-level data processing in a high speed, low latency data communications environment, including brokering establishment of an active message stream to a subscribing client device from an active feed adapter; brokering establishment of a backup message stream to the subscribing client device from a backup feed adapter; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter; receiving and buffering backup transport packets; identifying a missing active transport packet; determining whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received.
-
Citations
20 Claims
-
1. A method of selecting application messages from an active feed adapter and a backup feed adapter for application-level data processing in a high speed, low latency data communications environment, the method comprising:
-
brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter, the active message stream comprising active application messages; brokering, by the stream administration server, establishment of a backup message stream to the subscribing client device from a backup feed adapter, the backup message stream comprising backup application messages representing duplicates of the active application messages; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter, each active transport packet including one or more active application messages, each active transport packet characterized by an active packet sequence number, the active application messages from the active transport packets used for further data processing by an application of the subscribing client device; receiving and buffering backup transport packets in the transport engine of the subscribing client device from the backup feed adapter, each backup transport packet including one or more backup application messages, each backup transport packet characterized by a backup packet sequence number and representing a duplicate of a corresponding active transport packet; identifying, by the transport engine in dependence upon the active packet sequence numbers, a missing active transport packet; determining, by the transport engine, whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing, by the transport engine, the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received from the backup feed adapter. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
-
9. Apparatus for selecting application messages from an active feed adapter and a backup feed adapter for application-level data processing 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 an active message stream to a subscribing client device from an active feed adapter, the active message stream comprising active application messages; brokering, by the stream administration server, establishment of a backup message stream to the subscribing client device from a backup feed adapter, the backup message stream comprising backup application messages representing duplicates of the active application messages; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter, each active transport packet including one or more active application messages, each active transport packet characterized by an active packet sequence number, the active application messages from the active transport packets used for further data processing by an application of the subscribing client device; receiving and buffering backup transport packets in the transport engine of the subscribing client device from the backup feed adapter, each backup transport packet including one or more backup application messages, each backup transport packet characterized by a backup packet sequence number and representing a duplicate of a corresponding active transport packet; identifying, by the transport engine in dependence upon the active packet sequence numbers, a missing active transport packet; determining, by the transport engine, whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing, by the transport engine, the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received from the backup feed adapter. - View Dependent Claims (10, 11, 12, 13)
-
-
14. A computer program product for selecting application messages from an active feed adapter and a backup feed adapter for application-level data processing 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 an active message stream to a subscribing client device from an active feed adapter, the active message stream comprising active application messages; brokering, by the stream administration server, establishment of a backup message stream to the subscribing client device from a backup feed adapter, the backup message stream comprising backup application messages representing duplicates of the active application messages; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter, each active transport packet including one or more active application messages, each active transport packet characterized by an active packet sequence number, the active application messages from the active transport packets used for further data processing by an application of the subscribing client device; receiving and buffering backup transport packets in the transport engine of the subscribing client device from the backup feed adapter, each backup transport packet including one or more backup application messages, each backup transport packet characterized by a backup packet sequence number and representing a duplicate of a corresponding active transport packet; identifying, by the transport engine in dependence upon the active packet sequence numbers, a missing active transport packet; determining, by the transport engine, whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing, by the transport engine, the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received from the backup feed adapter. - View Dependent Claims (15, 16, 17, 18, 19, 20)
-
Specification