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 2015/10/19 21:50:25 UTC
[3/3] usergrid git commit: merge
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/remove-inmemory-event-service
Commit: 00175cc61111c7bc67971c11b1049bb7ddbc7c2b
Parents: 5ecc57f
Author: Shawn Feldman <sf...@apache.org>
Authored: Mon Oct 19 13:25:15 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
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: