diff options
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; + } + } |