aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala
diff options
context:
space:
mode:
authorIvan Topolnak <itopolnak@despegar.com>2014-01-13 17:56:51 -0300
committerIvan Topolnak <itopolnak@despegar.com>2014-01-13 17:56:51 -0300
commit111ea55690351d0903e9902c525c781ef2d743a8 (patch)
tree003b0e1cf95f1d3cba55927422ff063c049a5cf9 /kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala
parent571e96665bb3cb3f20fb59209be63dabbb3148f4 (diff)
parent7a10c0ef2a6566229e8571f6d385ca2ff794cc20 (diff)
downloadKamon-111ea55690351d0903e9902c525c781ef2d743a8.tar.gz
Kamon-111ea55690351d0903e9902c525c781ef2d743a8.tar.bz2
Kamon-111ea55690351d0903e9902c525c781ef2d743a8.zip
Merge branch 'wip/trace-and-metrics-integration'
Conflicts: kamon-newrelic/src/main/scala/kamon/newrelic/NewRelicErrorLogger.scala
Diffstat (limited to 'kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala b/kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala
index da797fa1..44eb8c43 100644
--- a/kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala
+++ b/kamon-core/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala
@@ -15,17 +15,16 @@
* ========================================================== */
package kamon.instrumentation
-import com.codahale.metrics.{ ExponentiallyDecayingReservoir, Histogram }
import akka.dispatch.{ UnboundedMessageQueueSemantics, Envelope, MessageQueue }
import org.aspectj.lang.annotation.{ Around, Pointcut, DeclareMixin, Aspect }
import akka.actor.{ ActorSystem, ActorRef }
-import kamon.metric.{ Metrics, MetricDirectory }
import org.aspectj.lang.ProceedingJoinPoint
/**
* For Mailboxes we would like to track the queue size and message latency. Currently the latency
* will be gathered from the ActorCellMetrics.
*/
+/*
@Aspect
class MessageQueueInstrumentation {
@@ -74,4 +73,5 @@ class MonitoredMessageQueue(val delegate: MessageQueue, val queueSizeHistogram:
def hasMessages: Boolean = delegate.hasMessages
def cleanUp(owner: ActorRef, deadLetters: MessageQueue) = delegate.cleanUp(owner, deadLetters)
}
+*/