get or default change

Author: anandujayan

queue/src/main/java/com/bazaarvoice/emodb/queue/QueueModule.java

@@ -84,7 +84,11 @@ protected void configure() {
         bind(DedupEventStoreChannels.class).toInstance(DedupEventStoreChannels.isolated("__dedupq_write:", "__dedupq_read:"));
         bind(new TypeLiteral<Supplier<Boolean>>() {}).annotatedWith(DedupEnabled.class).toInstance(Suppliers.ofInstance(true));
         install(new EventStoreModule("bv.emodb.queue", _metricRegistry));
+        bind(KafkaAdminService.class).asEagerSingleton();
+        bind(KafkaProducerService.class).asEagerSingleton();
 
+        // Bind Step Function Service
+        bind(StepFunctionService.class).asEagerSingleton();
 
         // Bind the Queue instance that the rest of the application will consume
         bind(QueueService.class).to(DefaultQueueService.class).asEagerSingleton();

queue/src/main/java/com/bazaarvoice/emodb/queue/core/kafka/KafkaConfig.java

@@ -58,7 +58,7 @@ public class KafkaConfig {
             lingerMsConfig = parameterValues.getOrDefault("/" + UNIVERSE + "/emodb/kafka/lingerMs", "1");
 
             // Configures the Kafka broker addresses for producer connections.
-            bootstrapServersConfig = parameterValues.get("/" + UNIVERSE + "/emodb/kafka/bootstrapServers");
+            bootstrapServersConfig = parameterValues.getOrDefault("/" + UNIVERSE + "/emodb/kafka/bootstrapServers", "localhost:9092");
 
             logger.info("Kafka configurations loaded successfully from SSM.");
         } catch (AmazonServiceException e) {

queue/src/test/java/com/bazaarvoice/emodb/queue/QueueModuleTest.java

@@ -59,11 +59,6 @@ protected void configure() {
                 bind(HostDiscovery.class).annotatedWith(DedupQueueHostDiscovery.class).toInstance(mock(HostDiscovery.class));
                 bind(JobHandlerRegistry.class).toInstance(mock(JobHandlerRegistry.class));
                 bind(JobService.class).toInstance(mock(JobService.class));
-                bind (KafkaAdminService.class).asEagerSingleton();
-                bind(KafkaProducerService.class).asEagerSingleton();
-
-                // Bind Step Function Service
-                bind(StepFunctionService.class).asEagerSingleton();
 
                 MetricRegistry metricRegistry = new MetricRegistry();
                 bind(MetricRegistry.class).toInstance(metricRegistry);