summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2013-06-19 14:52:05 +0000
committerGordon Sim <gsim@apache.org>2013-06-19 14:52:05 +0000
commit36b93a14e9325a466bb4b231aa2bf4d9b68ecd5b (patch)
treeb2a4c81600b5f8c7f2eb94e9c4c1e77afe8d4f4a /qpid/cpp/src
parent6ac6c07b58ff4a257d61b5587d14ea15d3c0c88d (diff)
downloadqpid-python-36b93a14e9325a466bb4b231aa2bf4d9b68ecd5b.tar.gz
QPID-4854: signal connection establishment for broker initiated connections also
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1494645 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/amqp/Interconnect.cpp1
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);