System and method for providing quality of service in wide area messaging fabric
First Claim
1. A method for transmitting data according to at least one quality of service requirement for a message topic, the method comprising:
- calculating a message path specifying a sequence of broker computers selected from a network of interconnected broker computers, the sequence of broker computers including publisher brokers publishing messages with the message topic and subscriber brokers receiving messages with the message topic, the sequence commencing with an initial broker computer connected to a sending computer, the sequence terminating with a final broker computer connected to a receiving computer, the message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic;
transmitting a message from the initial broker computer to the receiving computer via the sequence of broker computers specified by the message path, the message including the message topic as metadata;
receiving quality of service metrics about the network of interconnected broker computers;
determining whether the message path fulfills the at least one quality of service requirement based on the quality of service metrics; and
if the message path is determined not to fulfill the at least one quality of service requirement, repeating the calculating step for a new message path specifying a new sequence of broker computers selected from the network of interconnected broker computers, the new message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic.
1 Assignment
0 Petitions
Accused Products
Abstract
Techniques for transmitting data according to at least one quality of service requirement. A message path is calculated specifying a sequence of broker computers selected from a network of interconnected broker computers. The message path is statistically estimated to fulfill the at least one quality of service requirement. Quality of service metrics are received about the network of interconnected broker computers. If the message path is determined not to fulfill the quality of service requirement, a new message path is calculated specifying a new sequence of broker computers selected from the network of interconnected broker computers. The new message path is statistically estimated to fulfill the at least one quality of service requirement.
32 Citations
25 Claims
-
1. A method for transmitting data according to at least one quality of service requirement for a message topic, the method comprising:
-
calculating a message path specifying a sequence of broker computers selected from a network of interconnected broker computers, the sequence of broker computers including publisher brokers publishing messages with the message topic and subscriber brokers receiving messages with the message topic, the sequence commencing with an initial broker computer connected to a sending computer, the sequence terminating with a final broker computer connected to a receiving computer, the message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic; transmitting a message from the initial broker computer to the receiving computer via the sequence of broker computers specified by the message path, the message including the message topic as metadata; receiving quality of service metrics about the network of interconnected broker computers; determining whether the message path fulfills the at least one quality of service requirement based on the quality of service metrics; and if the message path is determined not to fulfill the at least one quality of service requirement, repeating the calculating step for a new message path specifying a new sequence of broker computers selected from the network of interconnected broker computers, the new message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A broker computer coupled to a network of interconnected broker computers for transmitting data according to at least one quality of service requirement for a message topic, the broker computer comprising:
-
a calculating unit configured to calculate a message path specifying a sequence of broker computers selected from the network of interconnected broker computers, the sequence of broker computers including publisher brokers publishing messages with the message topic and subscriber brokers receiving messages with the message topic, the sequence commencing with an initial broker computer connected to a sending computer, the sequence terminating with a final broker computer connected to a receiving computer, the message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic; a transmitting unit configured to transmit a message from the initial broker computer to the receiving computer via the sequence of broker computers specified by the message path, the message including the message topic as metadata; a receiving unit configured to receive quality of service metrics about the network of interconnected broker computers; and a determining unit configured to determine whether the message path fulfills the at least one quality of service requirement based on the quality of service metrics and, if the message path is determined not to fulfill the at least one quality of service requirement, to cause the calculating unit to calculate a new message path specifying a new sequence of broker computers selected from the network of interconnected broker computers, the new message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic. - View Dependent Claims (13, 14, 15, 16, 17, 18, 19, 20, 21, 22)
-
-
23. A computer program product for transmitting data according to at least one quality of service requirement, the computer program product comprising:
-
a non-transitory computer readable storage medium having computer readable program code embodied therewith, the computer readable program code configured to; calculate a message path specifying a sequence of broker computers selected from a network of interconnected broker computers, the sequence of broker computers including publisher brokers publishing messages with the message topic and subscriber brokers receiving messages with the message topic, the sequence commencing with an initial broker computer connected to a sending computer, the sequence terminating with a final broker computer connected to a receiving computer, the message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic; transmit a message from the initial broker computer to the receiving computer via the sequence of broker computers specified by the message path, the message including the message topic as metadata; receive quality of service metrics about the network of interconnected broker computers; determine whether the message path fulfills the at least one quality of service requirement based on the quality of service metrics; and if the message path is determined not to fulfill the at least one quality of service requirement, execute the calculate program code for a new message path specifying a new sequence of broker computers selected from the network of interconnected broker computers, the new message path being statistically estimated to fulfill the at least one quality of service requirement for the message topic. - View Dependent Claims (24, 25)
-
Specification