diff options
Diffstat (limited to 'java/common')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/Session.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/transport/Session.java b/java/common/src/main/java/org/apache/qpid/transport/Session.java index 06b606f2d3..9a9e131adc 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/Session.java +++ b/java/common/src/main/java/org/apache/qpid/transport/Session.java @@ -1195,4 +1195,12 @@ public class Session extends SessionInvoker } } } + + /** + * An auxiliary method for test purposes only + */ + public boolean isFlowBlocked() + { + return isFlowControlled() && credit.availablePermits() == 0; + } } |