merge
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/00175cc6 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/00175cc6 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/00175cc6 Branch: refs/heads/master Commit: 00175cc61111c7bc67971c11b1049bb7ddbc7c2b Parents: 5ecc57f Author: Shawn Feldman <[email protected]> Authored: Mon Oct 19 13:25:15 2015 -0600 Committer: Shawn Feldman <[email protected]> Committed: Mon Oct 19 13:25:15 2015 -0600 ---------------------------------------------------------------------- .../usergrid/corepersistence/asyncevents/AsyncIndexProvider.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/00175cc6/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncIndexProvider.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncIndexProvider.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncIndexProvider.java index fb63276..1ad9b86 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncIndexProvider.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncIndexProvider.java @@ -100,7 +100,7 @@ public class AsyncIndexProvider implements Provider<AsyncEventService> { switch (impl) { case LOCAL: AmazonAsyncEventService eventService = new AmazonAsyncEventService(scope -> new LocalQueueManager(), indexProcessorFig, indexProducer, metricsFactory, - entityCollectionManagerFactory, indexLocationStrategyFactory, entityIndexFactory, eventBuilder, rxTaskScheduler); + entityCollectionManagerFactory, indexLocationStrategyFactory, entityIndexFactory, eventBuilder, rxTaskScheduler,queueFig); eventService.MAX_TAKE = 1000; return eventService; case SQS:
