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/10/29 18:23:12 UTC
[10/18] git commit: add comments
add comments
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/ad0cce91
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/ad0cce91
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/ad0cce91
Branch: refs/heads/two-dot-o
Commit: ad0cce91dadc20525a2442a8c8d0a102cbeb83ad
Parents: bb25b5b
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Oct 28 08:48:59 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Oct 28 08:48:59 2014 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/services/notifications/QueueListener.java | 2 +-
.../usergrid/services/notifications/apns/EntityPushManager.java | 2 +-
.../usergrid/services/notifications/apns/ExpiredTokenListener.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/ad0cce91/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 ef87b3a..fffc8cd 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
@@ -97,10 +97,10 @@ public class QueueListener {
sleepBetweenRuns = new Long(properties.getProperty("usergrid.notifications.listener.sleep.between", ""+sleepBetweenRuns)).longValue();
sleepWhenNoneFound = new Long(properties.getProperty("usergrid.notifications.listener.sleep.after", ""+DEFAULT_SLEEP)).longValue();
batchSize = new Integer(properties.getProperty("usergrid.notifications.listener.batchSize", (""+batchSize)));
+ consecutiveCallsToRemoveDevices = new Integer(properties.getProperty("usergrid.notifications.inactive.interval", ""+200));
queueName = ApplicationQueueManager.getQueueNames(properties);
int maxThreads = new Integer(properties.getProperty("usergrid.notifications.listener.maxThreads", ""+MAX_THREADS));
- consecutiveCallsToRemoveDevices = new Integer(properties.getProperty("usergrid.notifications.inactive.interval", ""+100));
futures = new ArrayList<Future>(maxThreads);
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/ad0cce91/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/EntityPushManager.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/EntityPushManager.java b/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/EntityPushManager.java
index 29841f0..8283458 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/EntityPushManager.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/EntityPushManager.java
@@ -34,7 +34,7 @@ import java.security.KeyStore;
import java.util.concurrent.LinkedBlockingDeque;
/**
- * Classy class class.
+ * Store notifier within PushManager so it can be retrieved later. Need this for the async token listener
*/
public class EntityPushManager extends PushManager<SimpleApnsPushNotification> {
private final Notifier notifier;
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/ad0cce91/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/ExpiredTokenListener.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/ExpiredTokenListener.java b/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/ExpiredTokenListener.java
index 4c38013..3daa20c 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/ExpiredTokenListener.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/apns/ExpiredTokenListener.java
@@ -39,7 +39,7 @@ import java.util.HashMap;
import java.util.Map;
/**
- * Classy class class.
+ * Listen for token expirations and remove
*/
public class ExpiredTokenListener implements com.relayrides.pushy.apns.ExpiredTokenListener<SimpleApnsPushNotification> {