usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From snoopd...@apache.org
Subject [26/35] git commit: shorter transaction times; smaller batches
Date Wed, 01 Oct 2014 14:52:02 GMT
shorter transaction times; smaller batches


Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/48a3af16
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/48a3af16
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/48a3af16

Branch: refs/heads/two-dot-o-rebuildable-index
Commit: 48a3af163cbf120f55adab1d16bb91edaba1af66
Parents: 2ea3ee1
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Mon Sep 29 16:07:54 2014 -0600
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Mon Sep 29 16:07:54 2014 -0600

----------------------------------------------------------------------
 .../apache/usergrid/services/notifications/QueueListener.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/48a3af16/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 42f9dc4..31df5e7 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
@@ -35,12 +35,12 @@ import java.util.concurrent.Future;
 import java.util.concurrent.atomic.AtomicInteger;
 
 public class QueueListener  {
-    public  final long MESSAGE_TRANSACTION_TIMEOUT = 60 * 5 * 1000;
+    public  final long MESSAGE_TRANSACTION_TIMEOUT =  1 * 60 * 1000;
+
     public   long DEFAULT_SLEEP = 5000;
 
     private static final Logger LOG = LoggerFactory.getLogger(QueueListener.class);
 
-
     private MetricsFactory metricsService;
 
     private ServiceManagerFactory smf;
@@ -62,7 +62,7 @@ public class QueueListener  {
     private List<Future> futures;
 
     public  final String MAX_THREADS = "2";
-    private Integer batchSize = 1000;
+    private Integer batchSize = 100;
     private String[] queueNames;
 
 


Mime
View raw message