qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rob...@apache.org
Subject [6/8] qpid-jms git commit: QPIDJMS-112: add some more trace logging to aid diagnosis of behaviour
Date Fri, 18 Sep 2015 16:30:30 GMT
QPIDJMS-112: add some more trace logging to aid diagnosis of behaviour


Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/1ef43ed6
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/1ef43ed6
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/1ef43ed6

Branch: refs/heads/master
Commit: 1ef43ed62ac824b4900d501d2be71386abc9f28d
Parents: bdadbb6
Author: Robert Gemmell <robbie@apache.org>
Authored: Fri Sep 18 17:16:59 2015 +0100
Committer: Robert Gemmell <robbie@apache.org>
Committed: Fri Sep 18 17:16:59 2015 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java | 2 ++
 .../org/apache/qpid/jms/provider/failover/FailoverProvider.java   | 3 ++-
 2 files changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/1ef43ed6/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
index c84f2e5..c7e59cb 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java
@@ -113,10 +113,12 @@ public class AmqpConsumer extends AmqpAbstractResource<JmsConsumerInfo,
Receiver
     }
 
     private void stopOnSchedule(long timeout, final AsyncResult request) {
+        LOG.trace("Consumer {} scheduling stop", getConsumerId());
         // We need to drain the credit if no message(s) arrive to use it.
         final ScheduledFuture<?> future = getSession().schedule(new Runnable() {
             @Override
             public void run() {
+                LOG.trace("Consumer {} running scheduled stop", getConsumerId());
                 if (getEndpoint().getRemoteCredit() != 0) {
                     stop(request);
                     // TODO: We close the proton transport head to avoid this doing any writes
if

http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/1ef43ed6/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
index 91c6349..d6fd9b4 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
@@ -916,6 +916,7 @@ public class FailoverProvider extends DefaultProviderListener implements
Provide
 
         public FailoverRequest(AsyncResult watcher) {
             super(watcher);
+            LOG.trace("Created Failover Task: {} ({})", this, id);
         }
 
         @Override
@@ -995,7 +996,7 @@ public class FailoverProvider extends DefaultProviderListener implements
Provide
             } else if (succeedsWhenOffline()) {
                 onSuccess();
             } else {
-                LOG.trace("Task {} held until connection recovered:", this);
+                LOG.trace("Failover task held until connection recovered: {} ({})", this,
id);
             }
         }
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message