You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/07/11 19:29:03 UTC
activemq-artemis git commit: ARTEMIS-1280 removing non used future
Repository: activemq-artemis
Updated Branches:
refs/heads/master 99017aaee -> 24d0a6c8f
ARTEMIS-1280 removing non used future
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/24d0a6c8
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/24d0a6c8
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/24d0a6c8
Branch: refs/heads/master
Commit: 24d0a6c8fed537bdbce042ca8a84f23237800b37
Parents: 99017aa
Author: Clebert Suconic <cl...@apache.org>
Authored: Tue Jul 11 15:10:53 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Jul 11 15:10:53 2017 -0400
----------------------------------------------------------------------
.../activemq/artemis/core/server/impl/QueueImpl.java | 10 ----------
1 file changed, 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/24d0a6c8/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
----------------------------------------------------------------------
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 e903100..d7f6364 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();