You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/08/28 23:51:05 UTC
qpid-jms git commit: QPIDJMS-51 Clean up some debug logging
Repository: qpid-jms
Updated Branches:
refs/heads/master dc75f4646 -> 0d805a611
QPIDJMS-51 Clean up some debug logging
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/0d805a61
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/0d805a61
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/0d805a61
Branch: refs/heads/master
Commit: 0d805a61180c3ba3f5d5e1551cd6eccf4eda28ea
Parents: dc75f46
Author: Timothy Bish <ta...@gmail.com>
Authored: Fri Aug 28 17:50:58 2015 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Fri Aug 28 17:50:58 2015 -0400
----------------------------------------------------------------------
.../src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java | 8 +-------
.../org/apache/qpid/jms/provider/amqp/AmqpQueueBrowser.java | 5 +++++
2 files changed, 6 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/0d805a61/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java
index d329c39..1cf076c 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsQueueBrowser.java
@@ -140,9 +140,6 @@ public class JmsQueueBrowser implements QueueBrowser, Enumeration<Message> {
if (next != null) {
return true;
}
-
- LOG.info("Browser {} read message", next);
-
} else {
return true;
}
@@ -231,10 +228,7 @@ public class JmsQueueBrowser implements QueueBrowser, Enumeration<Message> {
@Override
public void onInboundMessage(JmsInboundMessageDispatch envelope) {
if (envelope.getMessage() == null) {
-
- // TODO - Remove
- LOG.info("Browser {} read browse done.", getConsumerId());
-
+ LOG.trace("Browser {} read browse done.", getConsumerId());
browseDone.set(true);
}
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/0d805a61/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpQueueBrowser.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpQueueBrowser.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpQueueBrowser.java
index 7f191a6..a71dc2c 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpQueueBrowser.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpQueueBrowser.java
@@ -82,6 +82,11 @@ public class AmqpQueueBrowser extends AmqpConsumer {
return true;
}
+ @Override
+ public String toString() {
+ return "AmqpQueueBrowser { " + this.resource.getConsumerId() + " }";
+ }
+
//----- Inner classes used in message pull operations --------------------//
protected class BrowseEndPullRequest extends TimedPullRequest {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org