You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2014/09/30 22:00:06 UTC
git commit: change to info logging
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o c8547dd8d -> 72f1beae0
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
Commit: 72f1beae032ae51255f9c37c2199e429d3b4c7a7
Parents: c8547dd
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Sep 30 13:58:32 2014 -0600
Committer: Shawn Feldman <sf...@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;
}