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 2016/11/04 13:53:22 UTC
activemq-artemis git commit: NO-JIRA: Removing System.out debug
Repository: activemq-artemis
Updated Branches:
refs/heads/master cca527d57 -> 3ead28f58
NO-JIRA: Removing System.out debug
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/3ead28f5
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/3ead28f5
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/3ead28f5
Branch: refs/heads/master
Commit: 3ead28f587abfcdda229c1b89c1eb6b45687035d
Parents: cca527d
Author: Clebert Suconic <cl...@apache.org>
Authored: Fri Nov 4 09:47:05 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Fri Nov 4 09:52:34 2016 -0400
----------------------------------------------------------------------
.../org/apache/activemq/artemis/core/server/impl/QueueImpl.java | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/3ead28f5/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 56a33ef..e01c81e 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
@@ -2915,11 +2915,6 @@ public class QueueImpl implements Queue {
while (true) {
if (messagesIterator != null && messagesIterator.hasNext()) {
MessageReference msg = messagesIterator.next();
- if (msg.isPaged()) {
- System.out.println("** Rejecting because it's paged " + msg.getMessage());
- continue;
- }
-// System.out.println("** Returning because it's not paged " + msg.getMessage());
return msg;
} else {
break;