You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2009/01/22 22:54:50 UTC
svn commit: r736814 - /qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
Author: gsim
Date: Thu Jan 22 13:54:50 2009
New Revision: 736814
URL: http://svn.apache.org/viewvc?rev=736814&view=rev
Log:
QPID-1611: Patch from Mick Goulish to ensure queues are created in store in cluster configuration
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=736814&r1=736813&r2=736814&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Thu Jan 22 13:54:50 2009
@@ -708,6 +708,13 @@
noLocal = _settings.get(qpidNoLocal);
QPID_LOG(debug, "Configured queue with no-local=" << noLocal);
+ /* In some pathways (cluster sync) we may get to this
+ * point with a durable queue that does not yet have
+ * a store created for it.
+ */
+ if ( isDurable() && (! getPersistenceId() ) )
+ store->create(*this, _settings);
+
lastValueQueue= _settings.get(qpidLastValueQueue);
if (lastValueQueue) QPID_LOG(debug, "Configured queue as Last Value Queue");
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org