#400 Adopted KafkaHandler constructor

swisspost · Jan 6, 2022 · ab08c2f · ab08c2f
1 parent 138a5b4
commit ab08c2f
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaHandler.java b/gateleen-kafka/src/main/java/org/swisspush/gateleen/kafka/KafkaHandler.java
@@ -58,21 +58,23 @@ public KafkaHandler(ConfigurationResourceManager configurationResourceManager, K
     public KafkaHandler(ConfigurationResourceManager configurationResourceManager, KafkaMessageValidator kafkaMessageValidator,
                         KafkaProducerRepository repository, KafkaMessageSender kafkaMessageSender, String configResourceUri,
                         String streamingPath) {
-        super(configurationResourceManager, configResourceUri, "gateleen_kafka_topic_configuration_schema");
-        this.kafkaMessageValidator = kafkaMessageValidator;
-        this.repository = repository;
-        this.kafkaMessageSender = kafkaMessageSender;
-        this.streamingPath = streamingPath;
-        this.properties = new HashMap<>();
-
-        this.topicExtractor = new KafkaTopicExtractor(streamingPath);
+        this(configurationResourceManager, kafkaMessageValidator, repository, kafkaMessageSender,
+                configResourceUri, streamingPath, new HashMap<>());
     }
 
     public KafkaHandler(ConfigurationResourceManager configurationResourceManager, KafkaProducerRepository repository,
     KafkaMessageSender kafkaMessageSender, String configResourceUri, String streamingPath, Map<String, Object> properties) {
 
+        this(configurationResourceManager, null, repository, kafkaMessageSender,
+                configResourceUri, streamingPath, properties);
+    }
+
+    public KafkaHandler(ConfigurationResourceManager configurationResourceManager, KafkaMessageValidator kafkaMessageValidator, KafkaProducerRepository repository,
+                        KafkaMessageSender kafkaMessageSender, String configResourceUri, String streamingPath, Map<String, Object> properties) {
+
         super(configurationResourceManager, configResourceUri, "gateleen_kafka_topic_configuration_schema");
         this.repository = repository;
+        this.kafkaMessageValidator = kafkaMessageValidator;
         this.kafkaMessageSender = kafkaMessageSender;
         this.streamingPath = streamingPath;
         this.properties = properties;