Reactive backpressure for East-West messaging in an embedded control cluster
AssigneeCisco Technology, Inc.
InventorsAn-Chun Chang, Gaurav Sharma
Life of this patent
Estimating the term…
Abstract
According to certain embodiments, a message bus system comprises a first client and a second client. The first client is configured to publish messages associated with a message topic to a message bus, and the second client is configured to receive the messages associated with the message topic from the message bus. The message bus system is configured to unsubscribe the second client from the message topic based at least in part on determining that a demand of the second client for the messages associated with the message topic has fallen below a threshold.
Claims19
A message bus system, comprising:
- a first client configured to publish messages associated with a message topic to a message bus;
- and
- a second client configured to receive the messages associated with the message topic from the message bus, wherein the message bus system is configured to:
- determine that a demand of the second client for the messages associated with the message topic has fallen below a first threshold;
- unsubscribe the second client from the message topic based, at least in part, on determining that the demand of the second client for the messages associated with the message topic has fallen below the first threshold;
- and
- throttle, by the message bus, a rate at which the first client publishes additional messages associated with the message topic to the message bus in response to determining that the demand has fallen below the first threshold.
A method, comprising:
- determining that a demand of a client for receiving messages associated with a message topic via a message bus has fallen below a first threshold;
- unsubscribing the client from the message topic based, at least in part, on determining that the demand of the client for receiving the messages associated with the message topic via the message bus has fallen below the first threshold;
- and
- throttling, by the message bus, a rate at which a publisher publishes additional messages associated with the message topic to the message bus in response to determining that the demand has fallen below the first threshold, wherein the publisher is a separate entity communicatively coupled to the message bus and configured to transmit messages to the client.
One or more computer-readable non-transitory storage media embodying instructions that, when executed by a processor, cause the performance of operations including:
- determining that a demand of a client for receiving messages associated with a message topic via a message bus has fallen below a first threshold;
- unsubscribing the client from the message topic based at least in part on determining that the demand of the client for receiving the messages associated with the message topic via the message bus has fallen below the first threshold;
- and
- throttling, by the message bus, a rate at which a publisher publishes additional messages associated with the message topic to the message bus in response to determining that the demand has fallen below the first threshold, wherein the publisher is a separate entity communicatively coupled to the message bus and configured to transmit messages to the client.
Dependencies are inferred from the claim text.