usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From snoopd...@apache.org
Subject [30/35] git commit: change to info logging
Date Wed, 01 Oct 2014 14:52:06 GMT
change to info logging


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/72f1beae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/72f1beae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/72f1beae

Branch: refs/heads/two-dot-o-rebuildable-index
Commit: 72f1beae032ae51255f9c37c2199e429d3b4c7a7
Parents: c8547dd
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Tue Sep 30 13:58:32 2014 -0600
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Tue Sep 30 13:58:32 2014 -0600

----------------------------------------------------------------------
 .../apache/usergrid/services/notifications/QueueListener.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/72f1beae/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
index 66edb78..10ca49f 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java
@@ -131,8 +131,9 @@ public class QueueListener  {
                 svcMgr = smf.getServiceManager(smf.getManagementAppId());
                 queueManager = svcMgr.getQueueManager();
                 String queueName = ApplicationQueueManager.getRandomQueue(queueNames);
+                LOG.info("getting from queue {} ", queueName);
                 QueueResults results = getDeliveryBatch(queueManager,queueName);
-                LOG.info("QueueListener: retrieved batch of {} messages", results.size());
+                LOG.info("QueueListener: retrieved batch of {} messages from queue {} ",
results.size(),queueName);
 
                 List<Message> messages = results.getMessages();
                 if (messages.size() > 0) {
@@ -217,9 +218,7 @@ public class QueueListener  {
         QueueQuery qq = new QueueQuery();
         qq.setLimit(this.getBatchSize());
         qq.setTimeout(MESSAGE_TRANSACTION_TIMEOUT);
-        LOG.debug("getting from queue {} ", queuePath);
         QueueResults results = queueManager.getFromQueue(queuePath, qq);
-        LOG.debug("got batch of {} devices from queue {} ", results.size(), queuePath);
         return results;
     }
 


Mime
View raw message