RELIABLE MESSAGING USING REDUNDANT MESSAGE STREAMS IN A HIGH SPEED, LOW LATENCY DATA COMMUNICATIONS ENVIRONMENT
First Claim
1. A method comprising:
- receiving active application messages that are part of an active message stream in a subscribing client device from an active feed adapter, wherein each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number;
receiving, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages that are part of a backup message stream in the subscribing client device from the backup feed adapter, wherein each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number;
administering, by 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; and
receiving, by the subscribing client device and from the backup feed adapter, the backup application messages, in response to the backup feed adapter receiving an administrative application message and an active message sequence number that specifies a point in a transmission sequence where the active feed adapter will transmit the administrative application message to the subscribing client device and in response to the backup feed adapter identifying a backup message sequence number of a most recent backup application message processed in the backup feed adapter prior to receiving the administrative application message and in response to the backup feed adapter determining that the backup feed adapter is capable of synchronizing transmission of the administrative application message to the subscribing client device on the backup message stream in dependence upon the received active message sequence number, the backup sequence number of the most recent message transmitted to the client device, and a predetermined synchronization sequence number threshold.
1 Assignment
0 Petitions
Accused Products
Abstract
A method includes receiving active application messages that are part of an active message stream in a subscribing client device from an active feed adapter. Each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number. The method includes receiving, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages in the subscribing client device from the backup feed adapter. Each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number. The method includes administering, by 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.
-
Citations
25 Claims
-
1. A method comprising:
-
receiving active application messages that are part of an active message stream in a subscribing client device from an active feed adapter, wherein each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number; receiving, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages that are part of a backup message stream in the subscribing client device from the backup feed adapter, wherein each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number; administering, by 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; and receiving, by the subscribing client device and from the backup feed adapter, the backup application messages, in response to the backup feed adapter receiving an administrative application message and an active message sequence number that specifies a point in a transmission sequence where the active feed adapter will transmit the administrative application message to the subscribing client device and in response to the backup feed adapter identifying a backup message sequence number of a most recent backup application message processed in the backup feed adapter prior to receiving the administrative application message and in response to the backup feed adapter determining that the backup feed adapter is capable of synchronizing transmission of the administrative application message to the subscribing client device on the backup message stream in dependence upon the received active message sequence number, the backup sequence number of the most recent message transmitted to the client device, and a predetermined synchronization sequence number threshold. - View Dependent Claims (2, 3, 4)
-
-
5. A method comprising:
-
transmitting, in response to a failover from an active feed adapter to a backup feed adapter, backup application messages to a subscribing client device from the backup feed adapter, wherein the backup application messages that are part of a backup message stream, wherein each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number, wherein the active feed adapter is configured to transmit active application messages that are part of an active source stream prior to the failover, wherein each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number, wherein each feed adapter comprises a device configured to convert messages on a feed adapter source stream having a first format to messages on a feed adapter output stream having a second format and transmit the messages on the feed adapter output stream to the subscribing client device; receiving, in the backup feed adapter from the active feed adapter, an administrative application message and an active message sequence number that specifies a point in a transmission sequence when the active feed adapter will transmit the administrative application message to the subscribing client device; identifying, by the backup feed adapter, a backup message sequence number of a most recent backup application message processed in the backup feed adapter prior to receiving the administrative application message; and determining, by the backup feed adapter, whether the backup feed adapter is capable of synchronizing transmission of the administrative application message to the subscribing client device on the backup message stream in dependence upon the received active message sequence number, the backup sequence number of the most recent message transmitted to the client device, and a predetermined synchronization sequence number threshold. - View Dependent Claims (6, 7, 8, 9, 10)
-
-
11. A computer program product for reliable messaging using redundant message streams, the computer program product comprising:
a computer readable storage medium having computer usable program code embodied therewith, the computer usable program code comprising a computer usable program code configured to; receive active application messages that are part of an active message stream in a subscribing client device from an active feed adapter, wherein each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number; receive, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages that are part of a backup message stream in the subscribing client device from the backup feed adapter, wherein each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number; administer, by 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; and receive, by the subscribing client device and from the backup feed adapter, the backup application messages, in response to the backup feed adapter receiving an administrative application message and an active message sequence number that specifies a point in a transmission sequence where the active feed adapter will transmit the administrative application message to the subscribing client device and in response to the backup feed adapter identifying a backup message sequence number of a most recent backup application message processed in the backup feed adapter prior to receiving the administrative application message and in response to the backup feed adapter determining that the backup feed adapter is capable of synchronizing transmission of the administrative application message to the subscribing client device on the backup message stream in dependence upon the received active message sequence number, the backup sequence number of the most recent message transmitted to the client device, and a predetermined synchronization sequence number threshold. - View Dependent Claims (12, 13, 14)
-
15. A computer program product for reliable messaging using redundant message streams, the computer program product comprising:
a computer readable storage medium having computer usable program code embodied therewith, the computer usable program code comprising a computer usable program code configured to; transmit, in response to a failover from an active feed adapter to a backup feed adapter, backup application messages to a subscribing client device from the backup feed adapter, wherein the backup application messages that are part of a backup message stream, wherein each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number, wherein the active feed adapter is configured to transmit active application messages that are part of an active source stream prior to the failover, wherein each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number, wherein each feed adapter comprises a device configured to convert messages on a feed adapter source stream having a first format to messages on a feed adapter output stream having a second format and transmit the messages on the feed adapter output stream to the subscribing client device; receive, in the backup feed adapter from the active feed adapter, an administrative application message and an active message sequence number that specifies a point in a transmission sequence when the active feed adapter will transmit the administrative application message to the subscribing client device; identify, by the backup feed adapter, a backup message sequence number of a most recent backup application message processed in the backup feed adapter prior to receiving the administrative application message; and determine, by the backup feed adapter, whether the backup feed adapter is capable of synchronizing transmission of the administrative application message to the subscribing client device on the backup message stream in dependence upon the received active message sequence number, the backup sequence number of the most recent message transmitted to the client device, and a predetermined synchronization sequence number threshold. - View Dependent Claims (16, 17, 18, 19, 20)
-
21. An apparatus comprising:
-
a processor; a messaging middleware executable on the processor, the messaging middleware configured to, transmit, in response to a failover from an active feed adapter to a backup feed adapter, backup application messages to a subscribing client device from the backup feed adapter, wherein the backup application messages that are part of a backup message stream, wherein each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number, wherein the active feed adapter is configured to transmit active application messages that are part of an active source stream prior to the failover, wherein each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number, wherein each feed adapter comprises a device configured to convert messages on a feed adapter source stream having a first format to messages on a feed adapter output stream having a second format and transmit the messages on the feed adapter output stream to the subscribing client device; receive, in the backup feed adapter from the active feed adapter, an administrative application message and an active message sequence number that specifies a point in a transmission sequence when the active feed adapter will transmit the administrative application message to the subscribing client device; identify, by the backup feed adapter, a backup message sequence number of a most recent backup application message processed in the backup feed adapter prior to receiving the administrative application message; and determine, by the backup feed adapter, whether the backup feed adapter is capable of synchronizing transmission of the administrative application message to the subscribing client device on the backup message stream in dependence upon the received active message sequence number, the backup sequence number of the most recent message transmitted to the client device, and a predetermined synchronization sequence number threshold. - View Dependent Claims (22, 23, 24, 25)
-
Specification