Updated to use SNS for the Queue Module
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/e4498b35 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/e4498b35 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/e4498b35 Branch: refs/heads/USERGRID-669 Commit: e4498b35e22cb7d3cde458298d8b1aedd0ae8811 Parents: 7aa26fc Author: Jeff West <jw...@apigee.com> Authored: Tue May 26 09:12:18 2015 -0700 Committer: Jeff West <jw...@apigee.com> Committed: Tue May 26 09:12:18 2015 -0700 ---------------------------------------------------------------------- .../usergrid/persistence/queue/guice/QueueModule.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/e4498b35/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/guice/QueueModule.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/guice/QueueModule.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/guice/QueueModule.java index 1b2d6ea..9224d7d 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/guice/QueueModule.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/guice/QueueModule.java @@ -18,6 +18,7 @@ package org.apache.usergrid.persistence.queue.guice; +import org.apache.usergrid.persistence.queue.impl.SNSQueueManagerImpl; import org.safehaus.guicyfig.GuicyFigModule; import org.apache.usergrid.persistence.queue.QueueFig; @@ -40,17 +41,12 @@ public class QueueModule extends AbstractModule { @Override protected void configure() { + install(new GuicyFigModule(QueueFig.class)); - install( new GuicyFigModule( QueueFig.class) ); - - // create a guice factory for getting our collection manager - install( new FactoryModuleBuilder().implement( QueueManager.class, SQSQueueManagerImpl.class ) - .build( QueueManagerFactory.class ) ); + install(new FactoryModuleBuilder().implement(QueueManager.class, SNSQueueManagerImpl.class) + .build(QueueManagerFactory.class)); } - } - -
