You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ni...@apache.org on 2018/07/12 14:55:07 UTC
[4/4] activemq-artemis git commit: NO-JIRA Removing System.err style
debug left by accident
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 <cl...@apache.org>
Authored: Wed Jul 11 14:34:34 2018 -0400
Committer: Francesco Nigro <ni...@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 {