aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-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
}