diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-05-03 22:46:16 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-05-03 22:46:16 +0000 |
| commit | 1cbdb20563e406d450a9632ccd503d04de49ff06 (patch) | |
| tree | 8731e0fc0d1124ab0bcef9bd876d7e42aa866083 /java/common | |
| parent | 4e115887da892949d4891df37d62d6ac46b61200 (diff) | |
| download | qpid-python-1cbdb20563e406d450a9632ccd503d04de49ff06.tar.gz | |
QPID-3233
If the underlying AMQP session gets closed, the JMS session is now notified along with details that caused the session closure.
The JMS Session will throw an exception (with an error code and details) when a user accesses the closed session.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1099288 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/Session.java | 3 |
1 files changed, 2 insertions, 1 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 b3c335ae68..862c37283b 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 @@ -1031,7 +1031,8 @@ public class Session extends SessionInvoker if(state == CLOSED) { - connection.removeSession(this); + connection.removeSession(this); + listener.closed(this); } } |