diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2015-02-10 23:52:08 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2015-02-10 23:52:08 +0000 |
commit | 77208f71328e3a62ab970401eae083980e94ab44 (patch) | |
tree | aa7b5e7710336f87005db16e2c7ec88450a918f8 | |
parent | 4072a4925990eedbaa36844902ca584132b66806 (diff) | |
download | qpid-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.java | 9 |
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(); + } } } |