Author: gsim
Date: Fri Apr 5 17:08:03 2013
New Revision: 1465048
URL: http://svn.apache.org/r1465048
Log:
QPID-4718: set exclusive owner on subscription queue
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp?rev=1465048&r1=1465047&r2=1465048&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp Fri Apr 5 17:08:03
2013
@@ -275,6 +275,7 @@ void Session::setupOutgoing(pn_link_t* l
//TODO: populate settings from source details when available from
engine
boost::shared_ptr<qpid::broker::Queue> queue
= broker.createQueue(name + qpid::types::Uuid(true).str(),
settings, this, "", connection.getUserid(), connection.getId()).first;
+ queue->setExclusiveOwner(this);
if (filter.hasSubjectFilter()) {
filter.bind(node.exchange, queue);
filter.write(pn_terminus_filter(pn_link_source(link)));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
