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/22 02:39:35 UTC
svn commit: r1619640 -
/qpid/branches/0.30/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
Author: aconway
Date: Fri Aug 22 00:39:35 2014
New Revision: 1619640
URL: http://svn.apache.org/r1619640
Log:
QPID-6012: HA Account for TX primary replication queues as HA user.
Previously they were not accounted which caused ACL notice messages.
Modified:
qpid/branches/0.30/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
Modified: qpid/branches/0.30/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/0.30/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp?rev=1619640&r1=1619639&r2=1619640&view=diff
==============================================================================
--- qpid/branches/0.30/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp (original)
+++ qpid/branches/0.30/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp Fri Aug 22 00:39:35 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