diff options
Diffstat (limited to 'src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala')
-rw-r--r-- | src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala b/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala index 75d6189c..c21502ac 100644 --- a/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala +++ b/src/main/scala/kamon/instrumentation/MessageQueueMetrics.scala @@ -1,7 +1,7 @@ package kamon.instrumentation import com.codahale.metrics.{ExponentiallyDecayingReservoir, Histogram} -import akka.dispatch.{Envelope, MessageQueue} +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} @@ -44,7 +44,7 @@ class MessageQueueInstrumentation { } -class MonitoredMessageQueue(val delegate: MessageQueue, val queueSizeHistogram: Histogram) extends MessageQueue { +class MonitoredMessageQueue(val delegate: MessageQueue, val queueSizeHistogram: Histogram) extends MessageQueue with UnboundedMessageQueueSemantics{ def enqueue(receiver: ActorRef, handle: Envelope) = { delegate.enqueue(receiver, handle) |