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/11/04 21:38:10 UTC
svn commit: r1538754 - in /qpid/trunk/qpid/cpp/src/qpid/broker/amqp_0_10:
Connection.cpp Connection.h
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