diff options
| author | Keith Wall <kwall@apache.org> | 2015-03-18 15:47:55 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2015-03-18 15:47:55 +0000 |
| commit | d7028167ca5314f3bea293f9aedc24254a218b6c (patch) | |
| tree | f43387a41fd820a47e4d7c6a09230f03ecd9fdd4 /qpid/java | |
| parent | a7fe37b2e987097beb116f6344e7252c54dbef2c (diff) | |
| download | qpid-python-d7028167ca5314f3bea293f9aedc24254a218b6c.tar.gz | |
QPID-6458: [Java Client] Prevent the client sending channel.flow (or message.stop) after the session has been closed by the client
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1667578 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 3966e75423..6c43396481 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -2425,7 +2425,10 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic void stop() throws AMQException { // Stop the server delivering messages to this session. - suspendChannel(true); + if (!(isClosed() || isClosing())) + { + suspendChannel(true); + } if (_dispatcher != null) { |