commit 9600b5c054a70b775bbf14d47fe4f6a3945a11d4
author William Kurkian <wkurkian@cisco.com> Thu Sep 20 16:05:59 2018 -0400
committer William Kurkian <wkurkian@cisco.com> Wed Sep 26 14:40:09 2018 -0400
tree 58dfb2296a31114cdb8dfb272e214566f7f00b37
parent 19d699e98a262a1a02ace57901ca5cf392752789

Replaced vnfsdk ves-aent library

Change-Id: I33b80abe0215eef8818b7bc9004f4de4b4f3aac3
Signed-off-by: William Kurkian <wkurkian@cisco.com>

src/main/java/kafka/VolthaKafkaConsumer.java

diff --git a/src/main/java/kafka/VolthaKafkaConsumer.java b/src/main/java/kafka/VolthaKafkaConsumer.java
index 11deb81..ba121e6 100644
--- a/src/main/java/kafka/VolthaKafkaConsumer.java
+++ b/src/main/java/kafka/VolthaKafkaConsumer.java
@@ -49,10 +49,12 @@
 
     private KafkaConsumerType type;
 
+    private VesAgent vesAgent;
+
     public VolthaKafkaConsumer(KafkaConsumerType type) {
         logger.debug("VolthaKafkaConsumer constructor called");
-        initVesAgent();
         this.type = type;
+        vesAgent = new VesAgent();
         try {
             consumer = createConsumer();
         } catch (Exception e) {
@@ -62,10 +64,6 @@
         }
     }
 
-    private void initVesAgent() {
-        VesAgent.initVes();
-    }
-
     private KafkaConsumer<Long, String> createConsumer() {
         logger.debug("Creating Kafka Consumer");
 
@@ -124,7 +122,7 @@
                     record.key(), record.value(),
                     record.partition(), record.offset());
                     logger.info("Attempting to send data to VES");
-                    boolean success = VesAgent.sendToVES(type, record.value());
+                    boolean success = vesAgent.sendToVES(type, record.value());
                     if (!success) {
                         throw new HTTPException(0);
                     } else {