Publish and subscribe data processing with failover using cascaded sequence numbers
First Claim
1. In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses,each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, and each of which having a means for receiving a published message on a first topic and assigning a broker-specific sequence number to the received message;
- a first broker apparatus comprising;
means for determining a failure of a neighboring broker apparatus which has provided published messages on the first topic to the first broker apparatus; and
means for sending historic resubscriptions with respect to the first topic to each antecedent broker apparatus of the failed neighboring broker apparatus by using the broker-specific sequence number corresponding to each antecedent broker apparatus.
1 Assignment
0 Petitions
Accused Products
Abstract
In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses, each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, and each of which having a means for receiving a published message on a first topic and assigning a broker-specific sequence number to the received message; a first broker apparatus has: a software unit for determining a failure of a neighboring broker apparatus which has provided published messages on the first topic to the first broker apparatus; and a software unit for sending historic resubscriptions with respect to the first topic to each antecedent broker apparatus of the failed neighboring broker apparatus by using the broker-specific sequence number corresponding to each antecedent broker apparatus.
73 Citations
10 Claims
-
1. In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses,
each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, and each of which having a means for receiving a published message on a first topic and assigning a broker-specific sequence number to the received message; -
a first broker apparatus comprising;
means for determining a failure of a neighboring broker apparatus which has provided published messages on the first topic to the first broker apparatus; and
means for sending historic resubscriptions with respect to the first topic to each antecedent broker apparatus of the failed neighboring broker apparatus by using the broker-specific sequence number corresponding to each antecedent broker apparatus. - View Dependent Claims (2, 3, 4, 5)
-
-
6. In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses,
each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, and each of which having a means for receiving a published message on a first topic and assigning a broker-specific sequence number to the received message; -
a broker data processing method carried out at a broker data processing apparatus, the method comprising steps of;
determining a failure of a neighboring broker apparatus which has provided published messages on the first topic to the first broker apparatus; and
sending historic resubscriptions with respect to the first topic to each antecedent broker apparatus of the failed neighboring broker apparatus by using the broker-specific sequence number corresponding to each antecedent broker apparatus. - View Dependent Claims (7, 8, 9)
-
-
10. A computer program product stored on a computer readable storage medium for, when run on a computer, carrying out, in a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses,
each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, and each of which having a means for receiving a published message on a first topic and assigning a broker-specific sequence number to the received message; -
a broker data processing method carried out at a broker data processing apparatus, the method comprising steps of;
determining a failure of a neighboring broker apparatus which has provided published messages on the first topic to the first broker apparatus; and
sending historic resubscriptions with respect to the first topic to each antecedent broker apparatus of the failed neighboring broker apparatus by using the broker-specific sequence number corresponding to each antecedent broker apparatus.
-
Specification