summaryrefslogtreecommitdiff
path: root/qpid/cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2014-12-17 14:29:13 +0000
committerGordon Sim <gsim@apache.org>2014-12-17 14:29:13 +0000
commitb5dba684ab72f5f8ea3e28672ba7e65668332dbc (patch)
tree90e0d73ef2ea48bb74fb5722f4913825aad2f6ee /qpid/cpp
parent87b282857f59a43fa77ab65a06ea55cd14de0e05 (diff)
downloadqpid-python-b5dba684ab72f5f8ea3e28672ba7e65668332dbc.tar.gz
QPID-5003: Use correct property for delayed auto-delete. Explicit 0 timeout should override default.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1646255 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
-rw-r--r--qpid/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp b/qpid/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp
index bbb310b0f4..920dd4172b 100644
--- a/qpid/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp
+++ b/qpid/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp
@@ -538,15 +538,16 @@ Subscription::Subscription(const Address& address, const std::string& type)
exclusiveSubscription((Opt(address)/LINK/X_SUBSCRIBE/EXCLUSIVE).asBool(exclusiveQueue)),
alternateExchange((Opt(address)/LINK/X_DECLARE/ALTERNATE_EXCHANGE).str())
{
- const Variant* timeout = (Opt(address)/LINK/TIMEOUT).value;
- if (timeout) {
+
+ if ((Opt(address)/LINK).hasKey(TIMEOUT)) {
+ const Variant* timeout = (Opt(address)/LINK/TIMEOUT).value;
if (timeout->asUint32()) queueOptions.setInt("qpid.auto_delete_timeout", timeout->asUint32());
} else if (durable && !(Opt(address)/LINK/RELIABILITY).value) {
//if durable but not explicitly reliable, then set a non-zero
//default for the autodelete timeout (previously this would
//have defaulted to autodelete immediately anyway, so the risk
//of the change causing problems is mitigated)
- queueOptions.setInt("qpid.auto_delete_delay", 15*60);
+ queueOptions.setInt("qpid.auto_delete_timeout", 15*60);
}
(Opt(address)/LINK/X_DECLARE/ARGUMENTS).collect(queueOptions);
(Opt(address)/LINK/X_SUBSCRIBE/ARGUMENTS).collect(subscriptionOptions);