diff options
| -rw-r--r-- | messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java index 54680976650..0f0b704bba7 100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java @@ -479,7 +479,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, * * @return The pending size. */ - synchronized int getPendingSize() { + public synchronized int getPendingSize() { return pendingSize; } @@ -512,6 +512,14 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler, } /** + * Gets maximum combined size of messages that can be received without + * being replied to yet. + */ + public int getMaxPendingSize() { + return maxPendingSize; + } + + /** * <p>Returns a named routing table, may return null.</p> * * @param name The name of the routing table to return. |