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/master Commit: f064c499c042289c5bc31cdda7b34199701ec795 Parents: 30266e1 Author: Michael Russo <mru...@apigee.com> Authored: Fri Apr 15 10:12:23 2016 +0200 Committer: Michael Russo <mru...@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 -> {