qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kp...@apache.org
Subject svn commit: r1064711 - /qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
Date Fri, 28 Jan 2011 14:56:02 GMT
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:commits-subscribe@qpid.apache.org


Mime
View raw message