diff options
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp b/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp index c30ea25dce..f7f12be6c4 100644 --- a/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp +++ b/qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp @@ -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); |