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 22:53:12 UTC
git commit: move logging turn down threads
Repository: incubator-usergrid
Updated Branches:
refs/heads/two-dot-o ddf60e98c -> 196249344
move logging turn down threads
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/19624934
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/19624934
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/19624934
Branch: refs/heads/two-dot-o
Commit: 196249344340b9a6dca21c3e128c0942cd7b8c9f
Parents: ddf60e9
Author: Shawn Feldman <sf...@apache.org>
Authored: Thu Sep 18 12:28:33 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Thu Sep 18 12:28:33 2014 -0600
----------------------------------------------------------------------
.../usergrid/services/notifications/ApplicationQueueManager.java | 2 +-
.../org/apache/usergrid/services/notifications/QueueListener.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/19624934/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 16e42e9..32e0c39 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
@@ -179,7 +179,6 @@ public class ApplicationQueueManager implements QueueManager {
ApplicationQueueMessage message = new ApplicationQueueMessage(appId, notification.getUuid(), deviceRef.getUuid(), notifierKey, notifierId);
LOG.info("ApplicationQueueMessage: notification {} pre-queue to device {} ", notification.getUuid(), deviceRef.getUuid());
- LOG.info("ApplicationQueueMessage: notification {} post-queue to device {} ", notification.getUuid(), deviceRef.getUuid());
if (notification.getQueued() == null) {
// update queued time
notification.setQueued(System.currentTimeMillis());
@@ -187,6 +186,7 @@ public class ApplicationQueueManager implements QueueManager {
LOG.info("ApplicationQueueMessage: notification {} queue time set.", notification.getUuid(), deviceRef.getUuid());
}
qm.postToQueue(QUEUE_NAME, message);
+ LOG.info("ApplicationQueueMessage: notification {} post-queue to device {} ", notification.getUuid(), deviceRef.getUuid());
deviceCount.incrementAndGet();
queueMeter.mark();
}
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/19624934/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 f9db3e4..bbaebcf 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
@@ -68,7 +68,7 @@ public class QueueListener {
ExecutorService pool;
List<Future> futures;
- public static final String MAX_THREADS = "4";
+ public static final String MAX_THREADS = "1";
public QueueListener() {
pool = Executors.newFixedThreadPool(1);