You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by pm...@apache.org on 2014/02/28 15:40:23 UTC
svn commit: r1572963 - in /qpid/trunk/qpid/cpp/src/qpid/broker: Queue.cpp
Queue.h management-schema.xml
Author: pmoravec
Date: Fri Feb 28 14:40:23 2014
New Revision: 1572963
URL: http://svn.apache.org/r1572963
Log:
QPID-5587: QMF to track queue owner (userId)
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
qpid/trunk/qpid/cpp/src/qpid/broker/Queue.h
qpid/trunk/qpid/cpp/src/qpid/broker/management-schema.xml
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=1572963&r1=1572962&r2=1572963&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Fri Feb 28 14:40:23 2014
@@ -1660,6 +1660,12 @@ void Queue::setMgmtRedirectState( std::s
}
}
+void Queue::setOwningUser(std::string& _userId) {
+ userId = _userId;
+ if (mgmtObject != 0)
+ mgmtObject->set_creator(userId);
+}
+
bool Queue::reroute(boost::shared_ptr<Exchange> e, const Message& m)
{
if (e) {
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Queue.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.h?rev=1572963&r1=1572962&r2=1572963&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Queue.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Queue.h Fri Feb 28 14:40:23 2014
@@ -400,7 +400,7 @@ class Queue : public boost::enable_share
QPID_BROKER_EXTERN bool find(framing::SequenceNumber pos, Message& msg ) const;
// Remember the queue's owner so acl quotas can be restored after restart
- void setOwningUser(std::string& _userId) { userId = _userId; }
+ void setOwningUser(std::string& _userId);
void updateAclUserQueueCount();
QPID_BROKER_EXTERN void setAlternateExchange(boost::shared_ptr<Exchange> exchange);
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/management-schema.xml
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/management-schema.xml?rev=1572963&r1=1572962&r2=1572963&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/management-schema.xml (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/management-schema.xml Fri Feb 28 14:40:23 2014
@@ -282,8 +282,9 @@
<statistic name="flowStopped" type="bool" desc="Flow control active."/>
<statistic name="flowStoppedCount" type="count32" desc="Number of times flow control was activated for this queue"/>
- <statistic name="redirectPeer" type="sstr" desc="Partner queue for redirected pair"/>
- <statistic name="redirectSource" type="bool" desc="This queue is the redirect source"/>
+ <statistic name="redirectPeer" type="sstr" desc="Partner queue for redirected pair"/>
+ <statistic name="redirectSource" type="bool" desc="This queue is the redirect source"/>
+ <statistic name="creator" type="sstr" desc="userId of creator of the queue"/>
<method name="purge" desc="Discard all or some messages on a queue">
<arg name="request" dir="I" type="uint32" desc="0 for all messages or n>0 for n messages"/>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org