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 <snoopd...@apache.org> Authored: Wed Nov 9 10:46:26 2016 -0500 Committer: Dave Johnson <snoopd...@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(
