Author: kpvdr
Date: Fri Jan 28 14:56:01 2011
New Revision: 1064711
URL: http://svn.apache.org/viewvc?rev=1064711&view=rev
Log:
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.
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp?rev=1064711&r1=1064710&r2=1064711&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp Fri Jan 28 14:56:01
2011
@@ -371,7 +371,8 @@ void SessionAdapter::QueueHandlerImpl::d
}
//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);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
