summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2011-01-28 14:56:01 +0000
committerKim van der Riet <kpvdr@apache.org>2011-01-28 14:56:01 +0000
commit51f31e3bc3becc4714a9a29f7edd3ebd63cad97e (patch)
tree62331136231051d1faeeb749cfe7ba0eb271d16c /qpid/cpp/src
parenteb257d87dd7420516e481cc38983053b0eb9ebf2 (diff)
downloadqpid-python-51f31e3bc3becc4714a9a29f7edd3ebd63cad97e.tar.gz
Fix for RHBZ656385: "Data store can become corrupt with small store file size and large wcache-page-size". The second issue from comments 13-16 in which the queue remains after the store throws the exception is solved.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1064711 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/SessionAdapter.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/SessionAdapter.cpp b/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
index d4f6b28ccb..3d62e73185 100644
--- a/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
+++ b/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
@@ -371,7 +371,8 @@ void SessionAdapter::QueueHandlerImpl::declare(const string& name, const string&
}
//apply settings & create persistent record if required
- queue_created.first->create(arguments);
+ try { queue_created.first->create(arguments); }
+ catch (...) { getBroker().getQueues().destroy(name); throw; }
//add default binding:
getBroker().getExchanges().getDefault()->bind(queue, name, 0);