summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2015-02-10 23:52:08 +0000
committerRobert Godfrey <rgodfrey@apache.org>2015-02-10 23:52:08 +0000
commit77208f71328e3a62ab970401eae083980e94ab44 (patch)
treeaa7b5e7710336f87005db16e2c7ec88450a918f8
parent4072a4925990eedbaa36844902ca584132b66806 (diff)
downloadqpid-python-77208f71328e3a62ab970401eae083980e94ab44.tar.gz
QPID-6380 : close()ing a durable subscription should detach rather than close a link
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1658843 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java9
1 files changed, 8 insertions, 1 deletions
diff --git a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java
index b89025a27b..4b53cfa795 100644
--- a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java
+++ b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/TopicSubscriberImpl.java
@@ -131,6 +131,13 @@ public class TopicSubscriberImpl extends MessageConsumerImpl implements TopicSub
protected void closeUnderlyingReceiver(Receiver receiver)
{
- receiver.close();
+ if(isDurable())
+ {
+ receiver.detach();
+ }
+ else
+ {
+ receiver.close();
+ }
}
}