From 6d30dcbdc6d8a4b2633f47f5076335d5a06518b3 Mon Sep 17 00:00:00 2001
From: Wiktor Garbarek <wiktor.garbarek@nokia.com>
Date: Tue, 26 Jun 2018 16:24:27 +0200
Subject: Refactor of KafkaEventConsumer

Moved constructor; added annotations

Change-Id: I26c81b16381ed69e170b236cea684be615fa795b
Issue-ID: AAI-1248
Signed-off-by: Wiktor Garbarek <wiktor.garbarek@nokia.com>
---
 .../onap/aai/event/client/KafkaEventConsumer.java    | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)

diff --git a/event-client-kafka/src/main/java/org/onap/aai/event/client/KafkaEventConsumer.java b/event-client-kafka/src/main/java/org/onap/aai/event/client/KafkaEventConsumer.java
index 1deb90a..e08639b 100644
--- a/event-client-kafka/src/main/java/org/onap/aai/event/client/KafkaEventConsumer.java
+++ b/event-client-kafka/src/main/java/org/onap/aai/event/client/KafkaEventConsumer.java
@@ -49,6 +49,7 @@ public class KafkaEventConsumer implements EventConsumer {
 
     private static Logger log = LoggerFactory.getInstance().getLogger(KafkaEventConsumer.class);
 
+    @FunctionalInterface
     public interface KafkaConsumerFactory {
         public KafkaConsumer<String, String> createConsumer(Properties props);
     }
@@ -57,15 +58,6 @@ public class KafkaEventConsumer implements EventConsumer {
 
     private final KafkaConsumer<String, String> consumer;
 
-    /**
-     * Replace the consumer factory (intended to be used for testing purposes only).
-     * 
-     * @param consumerFactory
-     */
-    static void setConsumerFactory(KafkaConsumerFactory consumerFactory) {
-        KafkaEventConsumer.consumerFactory = consumerFactory;
-    }
-
     /**
      *
      * @param hosts - A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. The
@@ -89,6 +81,16 @@ public class KafkaEventConsumer implements EventConsumer {
         consumer.subscribe(Arrays.asList(topic));
     }
 
+    /**
+     * Replace the consumer factory (intended to be used for testing purposes only).
+     * 
+     * @param consumerFactory
+     */
+    static void setConsumerFactory(KafkaConsumerFactory consumerFactory) {
+        KafkaEventConsumer.consumerFactory = consumerFactory;
+    }
+
+    @Override
     public void close() {
         consumer.close();
     }
-- 
cgit 1.2.3-korg