You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2011/12/06 18:58:34 UTC
svn commit: r1211057 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Author: chirino
Date: Tue Dec 6 17:58:34 2011
New Revision: 1211057
URL: http://svn.apache.org/viewvc?rev=1211057&view=rev
Log:
Fixes APLO-102: Store and aggregate metrics for durable subscriptions
Patch provided by Stan Lewis. Thanks!
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala?rev=1211057&r1=1211056&r2=1211057&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala Tue Dec 6 17:58:34 2011
@@ -447,8 +447,11 @@ class Queue(val router: LocalRouter, val
swapped_in_size_max -= tune_queue_buffer;
trigger_swap
- this.destination_dto match {
+ destination_dto match {
+ case d:DurableSubscriptionDestinationDTO =>
+ DestinationMetricsSupport.add_destination_metrics(virtual_host.dead_dsub_metrics, get_queue_metrics)
case t:TopicDestinationDTO =>
+ // metrics are taken care of by topic
case _ =>
DestinationMetricsSupport.add_destination_metrics(virtual_host.dead_queue_metrics, get_queue_metrics)
}