Repository: activemq Updated Branches: refs/heads/master a5c2f3f42 -> 2013c6a54
Update some logging for better coverage Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2013c6a5 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2013c6a5 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2013c6a5 Branch: refs/heads/master Commit: 2013c6a54f483f0206e6727bd1088616ba98daa2 Parents: a5c2f3f Author: Timothy Bish <[email protected]> Authored: Thu Apr 16 18:46:40 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu Apr 16 18:46:40 2015 -0400 ---------------------------------------------------------------------- .../apache/activemq/transport/amqp/protocol/AmqpReceiver.java | 4 ++-- .../org/apache/activemq/transport/amqp/protocol/AmqpSender.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/2013c6a5/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java ---------------------------------------------------------------------- diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java index 6051cde..56ce1e7 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java @@ -220,7 +220,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver { delivery.disposition(rejected); } else { if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) { - LOG.trace("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId()); + LOG.debug("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId()); getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit()); } @@ -241,7 +241,7 @@ public class AmqpReceiver extends AmqpAbstractReceiver { }); } else { if (getEndpoint().getCredit() <= (getConfiguredReceiverCredit() * .2)) { - LOG.trace("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId()); + LOG.debug("Sending more credit ({}) to producer: {}", getConfiguredReceiverCredit() - getEndpoint().getCredit(), getProducerId()); getEndpoint().flow(getConfiguredReceiverCredit() - getEndpoint().getCredit()); session.pumpProtonToSocket(); } http://git-wip-us.apache.org/repos/asf/activemq/blob/2013c6a5/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java ---------------------------------------------------------------------- diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java index f273cee..eefcbe3 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java @@ -397,7 +397,7 @@ public class AmqpSender extends AmqpAbstractLink<Sender> { final ActiveMQMessage jms = temp; if (jms == null) { - LOG.info("End of browse signals endpoint drained."); + LOG.trace("Sender:[{}] browse done.", getEndpoint().getName()); // It's the end of browse signal in response to a MessagePull getEndpoint().drained(); draining = false;
