make app testable

Author: zhenik

data-pipeline/http-materializer/src/main/java/no/sysco/testing/kafka/pipeline/materializer/MaterializerApplication.java

@@ -34,6 +34,9 @@ public void start() {
  Runtime.getRuntime().addShutdownHook(new Thread(kafkaMessageMaterializer::stop));
  }
 
+ // for test
+ DatabaseWebService getDbWebService() { return dbWebService; }
+
  public static void main(String[] args) {
  // typesafe conf load
  final Config config = ConfigFactory.load();

data-pipeline/http-materializer/src/main/java/no/sysco/testing/kafka/pipeline/materializer/MaterializerConfig.java

@@ -50,7 +50,7 @@ public static final class KafkaConfig {
  public final String bootstrapServers;
  public final String schemaRegistryUrl;
  public final String sourceTopic;
- private KafkaConfig(String bootstrapServers, String schemaRegistryUrl, String sourceTopic) {
+ KafkaConfig(String bootstrapServers, String schemaRegistryUrl, String sourceTopic) {
  this.bootstrapServers = bootstrapServers;
  this.schemaRegistryUrl = schemaRegistryUrl;
  this.sourceTopic = sourceTopic;
@@ -67,7 +67,7 @@ private KafkaConfig(String bootstrapServers, String schemaRegistryUrl, String so
 
  public static final class DatabaseRestServiceConfig {
  public final String url;
- private DatabaseRestServiceConfig(String url) { this.url = url; }
+ DatabaseRestServiceConfig(String url) { this.url = url; }
 
  @Override public String toString() {
  return "DatabaseRestServiceConfig{" +