You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2013/06/19 16:52:05 UTC
svn commit: r1494645 -
/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp
Author: gsim
Date: Wed Jun 19 14:52:05 2013
New Revision: 1494645
URL: http://svn.apache.org/r1494645
Log:
QPID-4854: signal connection establishment for broker initiated connections also
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp?rev=1494645&r1=1494644&r2=1494645&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp Wed Jun 19 14:52:05 2013
@@ -84,6 +84,7 @@ void Interconnect::process()
QPID_LOG_CAT(debug, model, id << " interconnect opened");
pn_connection_set_container(connection, broker.getFederationTag().c_str());
pn_connection_open(connection);
+ out.connectionEstablished();
pn_session_t* s = pn_session(connection);
pn_session_open(s);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org