usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From snoopd...@apache.org
Subject [05/35] git commit: default threads to two; less logging; more queues
Date Wed, 01 Oct 2014 14:51:41 GMT
default threads to two; less logging; more queues


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

Branch: refs/heads/two-dot-o-rebuildable-index
Commit: 0dc230d3db278a3ec5dab2630862db0af6351e5c
Parents: 96ea029
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Fri Sep 26 17:05:02 2014 -0600
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Fri Sep 26 17:05:02 2014 -0600

----------------------------------------------------------------------
 .../usergrid/services/notifications/ApplicationQueueManager.java | 4 +---
 .../apache/usergrid/services/notifications/QueueListener.java    | 2 +-
 2 files changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/0dc230d3/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
b/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
index d9542ed..dac3b6a 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/ApplicationQueueManager.java
@@ -47,7 +47,7 @@ import java.util.concurrent.atomic.AtomicInteger;
  */
 public class ApplicationQueueManager implements QueueManager {
 
-    public static  String DEFAULT_QUEUE_NAME = "notifications/queuelistenerv1_20;notifications/queuelistenerv1_21";
+    public static  String DEFAULT_QUEUE_NAME = "notifications/queuelistenerv1_20;notifications/queuelistenerv1_21;notifications/queuelistenerv1_22";
     public static final String DEFAULT_QUEUE_PROPERTY = "usergrid.notifications.listener.queueName";
     private static final Logger LOG = LoggerFactory.getLogger(ApplicationQueueManager.class);
 
@@ -242,8 +242,6 @@ public class ApplicationQueueManager implements QueueManager {
         if (LOG.isInfoEnabled()) {
             long elapsed = notification.getQueued() != null ? notification.getQueued() -
startTime : 0;
             LOG.info("ApplicationQueueMessage: notification {} done queuing to {} devices
in "+elapsed+" ms",notification.getUuid().toString(),deviceCount.get());
-            LOG.info("ApplicationQueueMessage: notification {} finished in {} ms",notification.getUuid().toString(),elapsed);
-
         }
 
     }

http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/0dc230d3/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 234821b..6281ef9 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  {
     ExecutorService pool;
     List<Future> futures;
 
-    public static final String MAX_THREADS = "1";
+    public static final String MAX_THREADS = "2";
     private Integer batchSize = 1000;
     private String[] queueNames;
 


Mime
View raw message