usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mru...@apache.org
Subject usergrid git commit: Remove parallel processing of the iterator.
Date Fri, 15 Apr 2016 08:12:45 GMT
Repository: usergrid
Updated Branches:
  refs/heads/release-2.1.1 30266e13d -> f064c499c


Remove parallel processing of the iterator.


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

Branch: refs/heads/release-2.1.1
Commit: f064c499c042289c5bc31cdda7b34199701ec795
Parents: 30266e1
Author: Michael Russo <mrusso@apigee.com>
Authored: Fri Apr 15 10:12:23 2016 +0200
Committer: Michael Russo <mrusso@apigee.com>
Committed: Fri Apr 15 10:12:23 2016 +0200

----------------------------------------------------------------------
 .../services/notifications/impl/ApplicationQueueManagerImpl.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/f064c499/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
----------------------------------------------------------------------
diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
b/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
index faa9a02..2466164 100644
--- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
+++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/impl/ApplicationQueueManagerImpl.java
@@ -168,8 +168,6 @@ public class ApplicationQueueManagerImpl implements ApplicationQueueManager
{
             };
 
 
-
-            //process up to 10 concurrently
             Observable processMessagesObservable = Observable.create(new IteratorObservable<Entity>(iterator))
                 .flatMap(entity -> {
 
@@ -180,7 +178,7 @@ public class ApplicationQueueManagerImpl implements ApplicationQueueManager
{
                     // if it's not a device, drill down and get them
                     return Observable.from(getDevices(entity));
 
-                }, 50)
+                })
                 .distinct(ref -> ref.getUuid())
                 .map(sendMessageFunction)
                 .doOnNext( message -> {


Mime
View raw message