fixed default queue impl should be LocalQueue instead of AWSQueue

Erudika · Nov 24, 2021 · 2e086d9 · 2e086d9
1 parent c5e5835
commit 2e086d9
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/para-server/src/main/java/com/erudika/para/queue/QueueModule.java b/para-server/src/main/java/com/erudika/para/queue/QueueModule.java
@@ -32,11 +32,7 @@ public class QueueModule extends AbstractModule {
 	protected void configure() {
 		String selectedQueue = Config.getConfigParam("q", "");
 		if (StringUtils.isBlank(selectedQueue)) {
-			if ("embedded".equals(Config.ENVIRONMENT)) {
-				bindToDefault();
-			} else {
-				bind(Queue.class).to(AWSQueue.class).asEagerSingleton();
-			}
+			bindToDefault();
 		} else {
 			if ("sqs".equalsIgnoreCase(selectedQueue) ||
 					AWSQueue.class.getSimpleName().equalsIgnoreCase(selectedQueue)) {