correct misplaced backing queue metrics

bosun-monitor · Aug 14, 2015 · 98bf1d1 · 98bf1d1
1 parent 6ff3bcd
commit 98bf1d1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cmd/scollector/collectors/rabbitmq.go b/cmd/scollector/collectors/rabbitmq.go
@@ -236,11 +236,11 @@ func rabbitmqBackingQueueStatus(p string, ts opentsdb.TagSet, bqs rmqBackingQueu
 	var md opentsdb.MultiDataPoint
 	Add(&md, p+"avg_rate", bqs.AvgAckEgressRate, ts.Copy().Merge(opentsdb.TagSet{"method": "ack", "direction": "out"}),
 		metadata.Rate, metadata.Message, DescRmqBackingQueueStatusAvgAckEgressRate)
-	Add(&md, p+"avg_rate", bqs.AvgAckEgressRate, ts.Copy().Merge(opentsdb.TagSet{"method": "ack", "direction": "in"}),
+	Add(&md, p+"avg_rate", bqs.AvgAckIngressRate, ts.Copy().Merge(opentsdb.TagSet{"method": "ack", "direction": "in"}),
 		metadata.Rate, metadata.Message, DescRmqBackingQueueStatusAvgAckIngressRate)
-	Add(&md, p+"avg_rate", bqs.AvgAckEgressRate, ts.Copy().Merge(opentsdb.TagSet{"direction": "out"}),
+	Add(&md, p+"avg_rate", bqs.AvgEgressRate, ts.Copy().Merge(opentsdb.TagSet{"method": "noack", "direction": "out"}),
 		metadata.Rate, metadata.Message, DescRmqBackingQueueStatusAvgEgressRate)
-	Add(&md, p+"avg_rate", bqs.AvgAckEgressRate, ts.Copy().Merge(opentsdb.TagSet{"direction": "in"}),
+	Add(&md, p+"avg_rate", bqs.AvgIngressRate, ts.Copy().Merge(opentsdb.TagSet{"method": "noack", "direction": "in"}),
 		metadata.Rate, metadata.Message, DescRmqBackingQueueStatusAvgIngressRate)
 	Add(&md, p+"len", bqs.AvgAckEgressRate, ts,
 		metadata.Gauge, metadata.Message, DescRmqBackingQueueStatusLen)