diff options
Diffstat (limited to 'qpid/java/common')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java index 06f80be6dd..e1b4705cc8 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java @@ -93,8 +93,11 @@ public abstract class ConnectionDelegate @Override public void sessionDetached(Connection conn, SessionDetached dtc) { Session ssn = conn.getSession(dtc.getChannel()); - conn.unmap(ssn); - ssn.closed(); + if (ssn != null) + { + conn.unmap(ssn); + ssn.closed(); + } } } |