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:53:13 UTC
[34/52] [abbrv] git commit: default threads to two; less logging;
more queues
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/eventsystem
Commit: 0dc230d3db278a3ec5dab2630862db0af6351e5c
Parents: 96ea029
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Sep 26 17:05:02 2014 -0600
Committer: Shawn Feldman <sf...@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;