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 | |
| 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')
| -rw-r--r-- | messagebus/abi-spec.json | 3 | ||||
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/SourceSession.java | 4 |
2 files changed, 6 insertions, 1 deletions
diff --git a/messagebus/abi-spec.json b/messagebus/abi-spec.json index 039f22c7525..83bab8e4734 100644 --- a/messagebus/abi-spec.json +++ b/messagebus/abi-spec.json @@ -827,7 +827,8 @@ "public com.yahoo.messagebus.Result send(com.yahoo.messagebus.Message, java.lang.String, boolean)", "public com.yahoo.messagebus.ReplyHandler getReplyHandler()", "public int getPendingCount()", - "public com.yahoo.messagebus.SourceSession setTimeout(double)" + "public com.yahoo.messagebus.SourceSession setTimeout(double)", + "public com.yahoo.messagebus.ThrottlePolicy getThrottlePolicy()" ], "fields": [] }, 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; + } + } |