summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2012-11-01 13:32:01 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2012-11-01 13:32:01 +0000
commita21b7731216ca2040362746a87e2e8062bb30aa5 (patch)
tree3d024e4dd05356e3db9c82617aa060269d4cf24c /java
parent1668b7dfdddc02b75bbb696a1026887f68ffaea2 (diff)
downloadqpid-python-a21b7731216ca2040362746a87e2e8062bb30aa5.tar.gz
QPID-4408 Applying patch from Dejan Bosanac.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1404586 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
-rw-r--r--java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
index bfd3029ace..28aacc3f44 100644
--- a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
+++ b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
@@ -282,7 +282,7 @@ public class ConnectionImpl implements Connection, QueueConnection, TopicConnect
{
task.onClose();
}
- if(_state != State.UNCONNECTED ) {
+ if(_conn != null && _state != State.UNCONNECTED ) {
_conn.close();
}
_state = State.CLOSED;