Repository: activemq-artemis Updated Branches: refs/heads/2.6.x faf70e940 -> f6292e6f9
NO-JIRA Removing System.err style debug left by accident This is non critical. The message is only used by Queue.pause ATM. (cherry picked from commit 9a52766e51da1c1499cafe1b50caed3f03b5ab55) Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/f6292e6f Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/f6292e6f Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/f6292e6f Branch: refs/heads/2.6.x Commit: f6292e6f9f3a9bf5eddda9d47905d6dc131b5852 Parents: faf70e9 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Wed Jul 11 14:34:34 2018 -0400 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Tue Aug 7 19:43:20 2018 -0400 ---------------------------------------------------------------------- .../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/f6292e6f/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 5da8dc1..ccb8267 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); @@ -761,11 +759,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 {