diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-04-11 12:13:05 +0200 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-04-11 12:13:05 +0200 |
| commit | f076d99ebbc72e7c6fd90bee9c2a6941fd6254ad (patch) | |
| tree | b73af608355200c1a3b8d83fb55d8d7fe66529ac /messagebus/src/main/java/com/yahoo | |
| parent | e5b9d3a634e2d8a1ecf783ff69c129e48732afad (diff) | |
- Allow control of throttlepolicy per session.
- Move tests to same namespace as code to avoid polluting the public interface.
- Expose the throttlepolicy from SourceSession to avoid double bookeeping.
Diffstat (limited to 'messagebus/src/main/java/com/yahoo')
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java index 85892b4cb87..ad06aed43ec 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java @@ -393,4 +393,8 @@ public final class SourceSession implements ReplyHandler, MessageBus.SendBlocked return this; } + public ThrottlePolicy getThrottlePolicy() { + return throttlePolicy; + } + } |