From 9dc361be21ef6eded4380bff2863d510978498cc Mon Sep 17 00:00:00 2001 From: Ismael Juma Date: Wed, 15 Jul 2015 00:26:55 +0100 Subject: [PATCH] kafka-2320; Test commit --- core/src/main/scala/kafka/utils/timer/Timer.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/utils/timer/Timer.scala b/core/src/main/scala/kafka/utils/timer/Timer.scala index bdd0e75b93e4b..527f4848ab182 100644 --- a/core/src/main/scala/kafka/utils/timer/Timer.scala +++ b/core/src/main/scala/kafka/utils/timer/Timer.scala @@ -25,6 +25,7 @@ import kafka.utils.threadsafe @threadsafe class Timer(taskExecutor: ExecutorService, tickMs: Long = 1, wheelSize: Int = 20, startMs: Long = System.currentTimeMillis) { + // private[this] val delayQueue = new DelayQueue[TimerTaskList]() private[this] val taskCounter = new AtomicInteger(0) private[this] val timingWheel = new TimingWheel(