RELIABLE MESSAGING USING REDUNDANT MESSAGE STREAMS IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
First Claim
1. A method of reliable messaging using redundant message streams 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 capable of communicating active application messages, each active application message characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number;
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 capable of communicating backup application messages representing duplicates of the active application messages, each backup application message characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number;
receiving the active application messages in messaging middleware of the subscribing client device from the active feed adapter;
receiving, in response to a failover from the active feed adapter to the backup feed adapter, the backup application messages in the messaging middleware of the subscribing client device from the backup feed adapter; and
administering, by the messaging middleware of the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number.
2 Assignments
0 Petitions
Accused Products
Abstract
Methods, apparatus, and products are disclosed for reliable messaging using redundant message streams in a high speed, low latency data communications environment that include 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 capable of communicating active application messages; brokering, by the server, establishment of a backup message stream to the subscribing client device from a backup feed adapter, the backup message stream capable of communicating backup application messages representing duplicates of the active messages; receiving the active messages in messaging middleware of the subscribing client device; receiving, in response to a failover, the backup messages in the messaging middleware; and administering, by the messaging middleware, the backup messages in dependence upon an active stream source identifier, an active stream source sequence number, a backup stream source identifier, and a backup stream source sequence number.
-
Citations
20 Claims
-
1. A method of reliable messaging using redundant message streams 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 capable of communicating active application messages, each active application message characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number; 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 capable of communicating backup application messages representing duplicates of the active application messages, each backup application message characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number; receiving the active application messages in messaging middleware of the subscribing client device from the active feed adapter; receiving, in response to a failover from the active feed adapter to the backup feed adapter, the backup application messages in the messaging middleware of the subscribing client device from the backup feed adapter; and administering, by the messaging middleware of the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. Apparatus for reliable messaging using redundant message streams 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 processor, 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 capable of communicating active application messages, each active application message characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number; 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 capable of communicating backup application messages representing duplicates of the active application messages, each backup application message characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number; receiving the active application messages in messaging middleware of the subscribing client device from the active feed adapter; receiving, in response to a failover from the active feed adapter to the backup feed adapter, the backup application messages in the messaging middleware of the subscribing client device from the backup feed adapter; and administering, by the messaging middleware of the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number. - View Dependent Claims (12, 13, 14)
-
-
15. A computer program product for reliable messaging using redundant message streams 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 capable of communicating active application messages, each active application message characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number; 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 capable of communicating backup application messages representing duplicates of the active application messages, each backup application message characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number; receiving the active application messages in messaging middleware of the subscribing client device from the active feed adapter; receiving, in response to a failover from the active feed adapter to the backup feed adapter, the backup application messages in the messaging middleware of the subscribing client device from the backup feed adapter; and administering, by the messaging middleware of the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification