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 2018/08/07 23:43:52 UTC
activemq-artemis git commit: NO-JIRA Removing System.err style debug
left by accident
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 <cl...@apache.org>
Authored: Wed Jul 11 14:34:34 2018 -0400
Committer: Clebert Suconic <cl...@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 {