diff options
| -rw-r--r-- | qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp b/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp index c94ced7024..b38c1f717d 100644 --- a/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp +++ b/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp @@ -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.")); |