qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject svn commit: r1512218 - /qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp
Date Fri, 09 Aug 2013 09:32:28 GMT
Author: gsim
Date: Fri Aug  9 09:32:28 2013
New Revision: 1512218

URL: http://svn.apache.org/r1512218
Log:
QPID-5061: do exclusivity checks before registering link to avoid cancelling a subscription
that did not succeed

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=1512218&r1=1512217&r2=1512218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Session.cpp Fri Aug  9 09:32:28 2013
@@ -355,8 +355,8 @@ void Session::setupOutgoing(pn_link_t* l
         authorise.outgoing(node.exchange, queue, filter);
         filter.bind(node.exchange, queue);
         boost::shared_ptr<Outgoing> q(new OutgoingFromQueue(connection.getBroker(),
name, target, queue, link, *this, out, !shared, false));
-        outgoing[link] = q;
         q->init();
+        outgoing[link] = q;
     } else if (node.relay) {
         boost::shared_ptr<Outgoing> out(new OutgoingFromRelay(link, connection.getBroker(),
*this, name, target, pn_link_name(link), node.relay));
         outgoing[link] = out;



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message