diff options
Diffstat (limited to 'kamon-core/src/main')
-rw-r--r-- | kamon-core/src/main/scala/akka/instrumentation/UnboundedMailboxInstrumentation.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/kamon-core/src/main/scala/akka/instrumentation/UnboundedMailboxInstrumentation.scala b/kamon-core/src/main/scala/akka/instrumentation/UnboundedMailboxInstrumentation.scala index 6a335dfa..94cd82eb 100644 --- a/kamon-core/src/main/scala/akka/instrumentation/UnboundedMailboxInstrumentation.scala +++ b/kamon-core/src/main/scala/akka/instrumentation/UnboundedMailboxInstrumentation.scala @@ -39,20 +39,20 @@ class UnboundedMailboxInstrumentation { @After("dequeuePointcut(queue)") def afterDequeuePointcut(queue: MessageQueueSizeCounting): Unit = { - if (queue.queueSize.get() > 0) queue.queueSize.decrementAndGet() + if (queue.internalQueueSize.get() > 0) queue.internalQueueSize.decrementAndGet() } @After("enqueuePointcut(queue)") def afterEnqueue(queue: MessageQueueSizeCounting): Unit = { - queue.queueSize.incrementAndGet() + queue.internalQueueSize.incrementAndGet() } @Around("numberOfMessagesPointcut(queue)") def aroundNumberOfMessages(pjp: ProceedingJoinPoint, queue: MessageQueueSizeCounting): Any = { - queue.queueSize.get() + queue.internalQueueSize.get() } } trait MessageQueueSizeCounting { - val queueSize = new AtomicInteger + val internalQueueSize = new AtomicInteger } |