From 24d0a6c8fed537bdbce042ca8a84f23237800b37 Mon Sep 17 00:00:00 2001 From: Clebert Suconic <clebertsuconic@apache.org> Date: Tue, 11 Jul 2017 15:10:53 -0400 Subject: [PATCH] ARTEMIS-1280 removing non used future --- .../activemq/artemis/core/server/impl/QueueImpl.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java index e9031005a5..d7f6364102 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java @@ -207,8 +207,6 @@ public class QueueImpl implements Queue { private ScheduledFuture<?> redistributorFuture; - private ScheduledFuture<?> checkQueueSizeFuture; - // We cache the consumers here since we don't want to include the redistributor private final AtomicInteger consumersCount = new AtomicInteger(); @@ -724,10 +722,6 @@ public class QueueImpl implements Queue { @Override public void close() throws Exception { - if (checkQueueSizeFuture != null) { - checkQueueSizeFuture.cancel(false); - } - getExecutor().execute(new Runnable() { @Override public void run() { @@ -913,10 +907,6 @@ public class QueueImpl implements Queue { @Override protected void finalize() throws Throwable { - if (checkQueueSizeFuture != null) { - checkQueueSizeFuture.cancel(false); - } - cancelRedistributor(); super.finalize();