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 | 1affa4763f101a6fd16b2f24ac45fcc20c52af60 (patch) | |
tree | a6ab8eea79767f6c4a830b2842b70b2f143e51b3 /kamon-core | |
parent | 006b3e3a940694c82a42cf6958b1e030a29fe7fe (diff) | |
download | Kamon-1affa4763f101a6fd16b2f24ac45fcc20c52af60.tar.gz Kamon-1affa4763f101a6fd16b2f24ac45fcc20c52af60.tar.bz2 Kamon-1affa4763f101a6fd16b2f24ac45fcc20c52af60.zip |
= kamon-core: fixes a clash name in UnboundedMailboxIntrumentation
Diffstat (limited to 'kamon-core')
-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 } |