You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2015/04/17 00:46:54 UTC
activemq git commit: Update some logging for better coverage
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 <ta...@gmail.com>
Authored: Thu Apr 16 18:46:40 2015 -0400
Committer: Timothy Bish <ta...@gmail.com>
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;