You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2016/11/09 15:47:37 UTC
[3/4] usergrid git commit: Add back support for SNS queue manager impl
Add back support for SNS queue manager impl
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/f6e6d5d1
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/f6e6d5d1
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/f6e6d5d1
Branch: refs/heads/usergrid-1318-queue
Commit: f6e6d5d194b1e55679bc0f49af1c09efc8831b0f
Parents: 5a81eb2
Author: Dave Johnson <sn...@apache.org>
Authored: Wed Nov 9 10:46:26 2016 -0500
Committer: Dave Johnson <sn...@apache.org>
Committed: Wed Nov 9 10:46:26 2016 -0500
----------------------------------------------------------------------
.../asyncevents/AsyncIndexProvider.java | 14 ++++++++++++--
1 file changed, 12 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/f6e6d5d1/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 f4a9bd2..561dfdc 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
@@ -124,8 +124,18 @@ public class AsyncIndexProvider implements Provider<AsyncEventService> {
"Configuration value of SQS is no longer allowed. Use SNS instead with only a single region.");
case SNS:
- throw new IllegalArgumentException(
- "Configuration value of SNS is no longer allowed. Use MULTIREGION instead. ");
+ return new AsyncEventServiceImpl(
+ queueManagerFactory,
+ indexProcessorFig,
+ indexProducer,
+ metricsFactory,
+ entityCollectionManagerFactory,
+ indexLocationStrategyFactory,
+ entityIndexFactory,
+ eventBuilder,
+ mapManagerFactory,
+ queueFig,
+ rxTaskScheduler );
case MULTIREGION:
return new AsyncEventServiceImpl(