diff options
| author | Diego <diegolparra@gmail.com> | 2014-04-07 11:53:11 -0300 |
|---|---|---|
| committer | Diego <diegolparra@gmail.com> | 2014-04-07 11:53:11 -0300 |
| commit | 1f6e6d488f0658a02aa9ffff3ced8ae9f618c1a0 (patch) | |
| tree | 8e81f46675e87ac9ab7b284679845db16d9cb56c /kamon-core/src/main/scala/akka/instrumentation | |
| parent | 45c7988ab2fe5b83d67e51a903830ae68b54284e (diff) | |
| download | Kamon-1f6e6d488f0658a02aa9ffff3ced8ae9f618c1a0.tar.gz Kamon-1f6e6d488f0658a02aa9ffff3ced8ae9f618c1a0.tar.bz2 Kamon-1f6e6d488f0658a02aa9ffff3ced8ae9f618c1a0.zip | |
= kamon-core: fixes a clash name in UnboundedMailboxIntrumentation
Diffstat (limited to 'kamon-core/src/main/scala/akka/instrumentation')
| -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 } |