You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2014/09/29 22:52:50 UTC
[11/52] [abbrv] git commit: increment count
increment count
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/ca15f5ae
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/ca15f5ae
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/ca15f5ae
Branch: refs/heads/eventsystem
Commit: ca15f5ae1513aa21c1d2dbe7443b5c4254a0b649
Parents: fe9ab1c
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Sep 23 18:56:52 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Sep 23 18:56:52 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/ca15f5ae/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 e7ba00e..6e9a7ef 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
@@ -193,7 +193,7 @@ public class QueueListener {
}catch (Exception ex){
LOG.error("failed to dequeue",ex);
try {
- long sleeptime = sleepWhenNoneFound*(consecutiveExceptions.get()+1);
+ long sleeptime = sleepWhenNoneFound*(consecutiveExceptions.incrementAndGet());
LOG.info("sleeping due to failures {} ms", sleeptime);
Thread.sleep(sleeptime);
}catch (InterruptedException ie){