Do not remove public methods.
@@ -479,7 +479,7 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler,
*
* @return The pending size.
*/
- synchronized int getPendingSize() {
+ public synchronized int getPendingSize() {
return pendingSize;
}
@@ -511,6 +511,14 @@ public class MessageBus implements ConfigHandler, NetworkOwner, MessageHandler,
maxPendingSize = maxSize;
}
+ /**
+ * 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>
*
