qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject svn commit: r1538754 - in /qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10: Connection.cpp Connection.h
Date Mon, 04 Nov 2013 20:38:10 GMT
Author: gsim
Date: Mon Nov  4 20:38:10 2013
New Revision: 1538754

URL: http://svn.apache.org/r1538754
Log:
QPID-5292: restore raising of connection event and setting of authIdentity on mgmt object

Modified:
    qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.cpp
    qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.h

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.cpp?rev=1538754&r1=1538753&r2=1538754&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.cpp Mon Nov  4 20:38:10 2013
@@ -317,6 +317,17 @@ void Connection::setUserId(const string&
     isDefaultRealm = (
         at!= std::string::npos &&
         getBroker().getOptions().realm == userId.substr(at+1,userId.size()));
+   raiseConnectEvent();
+}
+
+void Connection::raiseConnectEvent() {
+    if (mgmtObject != 0) {
+        mgmtObject->set_authIdentity(userId);
+        agent->raiseEvent(_qmf::EventClientConnect(mgmtId, userId, mgmtObject->get_remoteProperties()));
+    }
+
+    QPID_LOG_CAT(debug, model, "Create connection. user:" << userId
+        << " rhost:" << mgmtId );
 }
 
 void Connection::setUserProxyAuth(bool b)

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.h?rev=1538754&r1=1538753&r2=1538754&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10/Connection.h Mon Nov  4 20:38:10 2013
@@ -220,6 +220,8 @@ class Connection : public sys::Connectio
     uint64_t objectId;
     types::Variant::Map clientProperties;
 
+    void raiseConnectEvent();
+
 friend class OutboundFrameTracker;
 
     void sent(const framing::AMQFrame& f);



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


Mime
View raw message