activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq git commit: Update some logging for better coverage
Date Thu, 16 Apr 2015 22:46:54 GMT
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 <tabish121@gmail.com>
Authored: Thu Apr 16 18:46:40 2015 -0400
Committer: Timothy Bish <tabish121@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;


Mime
View raw message