diff options
| author | Gordon Sim <gsim@apache.org> | 2013-06-06 11:30:16 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-06-06 11:30:16 +0000 |
| commit | 96d0590cd57fdbbf01ff25e0d25c5cda2923b151 (patch) | |
| tree | 6545edded96ffd71d34d1e49ebdec3b8b04ada1d /python | |
| parent | 69ab0b1a204d2e155f0ab9f5c06782a47b819d81 (diff) | |
| download | qpid-python-96d0590cd57fdbbf01ff25e0d25c5cda2923b151.tar.gz | |
QPID-4903: don't delete subscription queue when closing link if it was explicitly declared non-exclusive
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1490240 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
| -rw-r--r-- | python/qpid/messaging/driver.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/qpid/messaging/driver.py b/python/qpid/messaging/driver.py index 7a36745c33..ac59bcf0a6 100644 --- a/python/qpid/messaging/driver.py +++ b/python/qpid/messaging/driver.py @@ -233,7 +233,7 @@ class LinkIn: exclusive=True, auto_delete=(reliability == "unreliable")), overrides=declare) - _rcv.on_unlink = [QueueDelete(_rcv._queue)] + if declare.get("exclusive", True): _rcv.on_unlink = [QueueDelete(_rcv._queue)] subject = _rcv.subject or SUBJECT_DEFAULTS.get(subtype) bindings = get_bindings(link_opts, _rcv._queue, _rcv.name, subject) if not bindings: |