You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2014/08/15 12:01:29 UTC
svn commit: r1618133 - /qpid/trunk/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
Author: aconway
Date: Fri Aug 15 10:01:28 2014
New Revision: 1618133
URL: http://svn.apache.org/r1618133
Log:
NO-JIRA: HA Account for TX primary replication queues as HA user.
Previously they were not accounted which caused ACL notice messages.
Modified:
qpid/trunk/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp?rev=1618133&r1=1618132&r2=1618133&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp Fri Aug 15 10:01:28 2014
@@ -123,8 +123,13 @@ void PrimaryTxObserver::initialize() {
boost::shared_ptr<Exchange> ex(new Exchange(shared_from_this()));
broker.getExchanges().registerExchange(ex);
pair<QueuePtr, bool> result =
- broker.getQueues().declare(
- exchangeName, QueueSettings(/*durable*/false, /*autodelete*/true));
+ broker.createQueue(
+ exchangeName,
+ QueueSettings(/*durable*/false, /*autodelete*/true),
+ 0, // no owner regardless of exclusivity on primary
+ string(), // No alternate exchange
+ haBroker.getUserId(),
+ string()); // Remote host.
if (!result.second)
throw InvalidArgumentException(
QPID_MSG(logPrefix << "TX replication queue already exists."));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org