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/15 22:27:16 UTC
git commit: more logging
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o 1f8f35951 -> 1f46dd488
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/1f46dd48
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/1f46dd48
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/1f46dd48
Branch: refs/heads/two-dot-o
Commit: 1f46dd488b29e2b5e09c6087fd0f51054dc55b93
Parents: 1f8f359
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Sep 15 14:27:00 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Sep 15 14:27:00 2014 -0600
----------------------------------------------------------------------
.../usergrid/services/notifications/QueueListener.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/1f46dd48/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 01c02e3..bbaebcf 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
@@ -127,7 +127,7 @@ public class QueueListener {
while ( true ) {
try {
QueueResults results = ApplicationQueueManager.getDeliveryBatch(queueManager);
- LOG.info("QueueListener: retreived batch of {} messages",results.size());
+ LOG.info("QueueListener: retrieved batch of {} messages",results.size());
List<Message> messages = results.getMessages();
if(messages.size()>0) {
@@ -163,6 +163,7 @@ public class QueueListener {
.flatMap(new Func1<List<ApplicationQueueMessage>, Observable<?>>() {
@Override
public Observable<?> call(List<ApplicationQueueMessage> queueMessages) {
+ LOG.info("QueueListener: send batch {} messages", queueMessages.size());
return manager.sendBatchToProviders(queueMessages);
}
});
@@ -176,10 +177,11 @@ public class QueueListener {
})
.toBlocking()
.last();
- LOG.info("Messages sent in batch");
+ LOG.info("QueueListener: Messages sent in batch");
}
else{
+ LOG.info("QueueListener: no messages...sleep...",results.size());
Thread.sleep(sleepPeriod);
}
//send to the providers
@@ -195,6 +197,8 @@ public class QueueListener {
}
public void stop(){
+ LOG.info("QueueListener: stop processes");
+
for(Future future : futures){
future.cancel(true);
}