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/20 00:15:18 UTC
[2/2] git commit: add optional sleep value
add optional sleep value
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/bc6fbd56
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/bc6fbd56
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/bc6fbd56
Branch: refs/heads/two-dot-o
Commit: bc6fbd561ea36a7a6b54d8e50cf443b781d5eef4
Parents: 810bc19
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Sep 19 16:14:58 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Sep 19 16:14:58 2014 -0600
----------------------------------------------------------------------
.../usergrid/services/notifications/QueueListener.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/bc6fbd56/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 5cb1bfe..ae54008 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
@@ -63,7 +63,7 @@ public class QueueListener {
private ServiceManager svcMgr;
- private long sleepWhenNoneFound = 5000;
+ private long sleepWhenNoneFound = 0;
private long sleepBetweenRuns = 5000;
@@ -96,7 +96,7 @@ public class QueueListener {
int threadCount = 0;
try {
- sleepBetweenRuns = new Long(properties.getProperty("usergrid.notifications.listener.sleep.between", "5000")).longValue();
+ sleepBetweenRuns = new Long(properties.getProperty("usergrid.notifications.listener.sleep.between", "0")).longValue();
sleepWhenNoneFound = new Long(properties.getProperty("usergrid.notifications.listener.sleep.after", "5000")).longValue();
int maxThreads = new Integer(properties.getProperty("usergrid.notifications.listener.maxThreads", MAX_THREADS));
futures = new ArrayList<Future>(maxThreads);
@@ -188,10 +188,12 @@ public class QueueListener {
.toBlocking()
.last();
LOG.info("QueueListener: Messages sent in batch");
- Thread.sleep(sleepBetweenRuns);
+ if(sleepBetweenRuns > 0) {
+ Thread.sleep(sleepBetweenRuns);
+ }
}
else{
- LOG.info("QueueListener: no messages...sleep...",results.size());
+ LOG.info("QueueListener: no messages...sleep...", results.size());
Thread.sleep(sleepWhenNoneFound);
}
//send to the providers