NO-JIRA Removing System.err style debug left by accident This is non critical. The message is only used by Queue.pause ATM.
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9a52766e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9a52766e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9a52766e Branch: refs/heads/master Commit: 9a52766e51da1c1499cafe1b50caed3f03b5ab55 Parents: f126980 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Wed Jul 11 14:34:34 2018 -0400 Committer: Francesco Nigro <nigro....@gmail.com> Committed: Thu Jul 12 16:51:35 2018 +0200 ---------------------------------------------------------------------- .../apache/activemq/artemis/core/server/impl/QueueImpl.java | 7 ------- 1 file changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9a52766e/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 fdb0ddd..bc5c0c9 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 @@ -248,8 +248,6 @@ public class QueueImpl extends CriticalComponentImpl implements Queue { private final ReusableLatch deliveriesInTransit = new ReusableLatch(0); - private volatile boolean caused = false; - private final AtomicLong queueRateCheckTime = new AtomicLong(System.currentTimeMillis()); private final AtomicLong messagesAddedSnapshot = new AtomicLong(0); @@ -766,11 +764,6 @@ public class QueueImpl extends CriticalComponentImpl implements Queue { */ private boolean flushDeliveriesInTransit() { try { - - if (!deliveriesInTransit.await(100, TimeUnit.MILLISECONDS)) { - caused = true; - System.err.println("There are currently " + deliveriesInTransit.getCount() + " credits"); - } if (deliveriesInTransit.await(DELIVERY_TIMEOUT)) { return true; } else {
