aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDiego <diegolparra@gmail.com>2014-04-07 11:53:11 -0300
committerDiego <diegolparra@gmail.com>2014-04-07 11:53:11 -0300
commit1affa4763f101a6fd16b2f24ac45fcc20c52af60 (patch)
treea6ab8eea79767f6c4a830b2842b70b2f143e51b3
parent006b3e3a940694c82a42cf6958b1e030a29fe7fe (diff)
downloadKamon-1affa4763f101a6fd16b2f24ac45fcc20c52af60.tar.gz
Kamon-1affa4763f101a6fd16b2f24ac45fcc20c52af60.tar.bz2
Kamon-1affa4763f101a6fd16b2f24ac45fcc20c52af60.zip
= kamon-core: fixes a clash name in UnboundedMailboxIntrumentation
-rw-r--r--kamon-core/src/main/scala/akka/instrumentation/UnboundedMailboxInstrumentation.scala8
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
}