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/10/28 00:23:38 UTC
git commit: fix config of inactive devices
Repository: incubator-usergrid
Updated Branches:
refs/heads/pushy_4-0 f3343f1f8 -> bbed017f8
fix config of inactive devices
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/bbed017f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/bbed017f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/bbed017f
Branch: refs/heads/pushy_4-0
Commit: bbed017f80d04fb09b925304d0ae838ecfd3d329
Parents: f3343f1
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Oct 27 17:23:20 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Mon Oct 27 17:23:20 2014 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/services/notifications/QueueListener.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/bbed017f/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 286daf1..ef87b3a 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
@@ -209,7 +209,7 @@ public class QueueListener {
LOG.info("sleep between rounds...sleep...{}", sleepBetweenRuns);
Thread.sleep(sleepBetweenRuns);
}
- if(runCount++ % consecutiveCallsToRemoveDevices == 0){
+ if(++runCount % consecutiveCallsToRemoveDevices == 0){
for(ApplicationQueueManager applicationQueueManager : queueManagerMap.values()){
try {
applicationQueueManager.asyncCheckForInactiveDevices();