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/18 18:08:08 UTC
[2/2] git commit: adding back variable
adding back variable
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/29adda4b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/29adda4b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/29adda4b
Branch: refs/heads/two-dot-o
Commit: 29adda4bb94ceb1c36d5726ed9a3e582c1b56faa
Parents: 6ca107f
Author: Shawn Feldman <sf...@apache.org>
Authored: Thu Sep 18 10:01:19 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Thu Sep 18 10:01:19 2014 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/services/notifications/QueueJob.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/29adda4b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueJob.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueJob.java b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueJob.java
index 9f756a4..86c7b44 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueJob.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueJob.java
@@ -52,6 +52,8 @@ public class QueueJob extends OnlyOnceJob {
@Autowired
private ServiceManagerFactory smf;
+ static final long BATCH_DEATH_PERIOD = 10 * 60 * 1000;
+
@Autowired
private EntityManagerFactory emf;
private Histogram histogram;
@@ -120,7 +122,7 @@ public class QueueJob extends OnlyOnceJob {
@Override
protected long getDelay( JobExecution execution ) throws Exception {
- return TaskManager.BATCH_DEATH_PERIOD;
+ return BATCH_DEATH_PERIOD;
}