You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2014/10/01 16:52:05 UTC
[29/35] git commit: more logging
more 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/c8547dd8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/c8547dd8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/c8547dd8
Branch: refs/heads/two-dot-o-rebuildable-index
Commit: c8547dd8d0348864303e26370efabb0975b4f866
Parents: 9ce8346
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Sep 30 12:31:00 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Sep 30 12:31:00 2014 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/services/notifications/QueueListener.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/c8547dd8/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 31df5e7..66edb78 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
@@ -217,8 +217,9 @@ 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", results.size());
+ LOG.debug("got batch of {} devices from queue {} ", results.size(), queuePath);
return results;
}