Either log or rethrow this exception

[aai/router-core.git] / src / main / java / org / onap / aai / event / EventBusConsumer.java

diff --git a/src/main/java/org/onap/aai/event/EventBusConsumer.java b/src/main/java/org/onap/aai/event/EventBusConsumer.java
index 1787995..1faca7a 100644 (file)
--- a/src/main/java/org/onap/aai/event/EventBusConsumer.java
+++ b/src/main/java/org/onap/aai/event/EventBusConsumer.java
@@ -89,7 +89,7 @@ public class EventBusConsumer extends ScheduledPollConsumer {
       consumer = consumerBuilder.build();
 
     } catch (MalformedURLException | GeneralSecurityException e) {
-      logger.error(RouterCoreMsgs.EVENT_CONSUMER_CREATION_EXCEPTION, e.getLocalizedMessage());
+      logger.error(RouterCoreMsgs.EVENT_CONSUMER_CREATION_EXCEPTION, e, e.getLocalizedMessage());
     }
   }
 
@@ -106,9 +106,7 @@ public class EventBusConsumer extends ScheduledPollConsumer {
 
     int processCount = 0;
 
-    Iterable<String> messages = null;
-
-    messages = consumer.fetch();
+    Iterable<String> messages = consumer.fetch();
 
     String topic = endpoint.getEventTopic();
 
@@ -120,14 +118,14 @@ public class EventBusConsumer extends ScheduledPollConsumer {
     }
     return processCount;
   }
-
+  @Override
   protected void doStop() throws Exception {
     super.doStop();
     if (consumer != null) {
       consumer.close();
     }
   }
-
+  @Override
   protected void doShutdown() throws Exception {
     super.doShutdown();
     if (consumer != null) {
@@ -148,7 +146,7 @@ public class EventBusConsumer extends ScheduledPollConsumer {
       this.message = message;
       this.topic = topic;
     }
-
+       @Override
     public void run() {
       try {
 
@@ -163,7 +161,7 @@ public class EventBusConsumer extends ScheduledPollConsumer {
         }
 
       } catch (Exception e) {
-        logger.error(RouterCoreMsgs.EVENT_PROCESSING_EXCEPTION, e.getLocalizedMessage());
+        logger.error(RouterCoreMsgs.EVENT_PROCESSING_EXCEPTION,e,e.getLocalizedMessage());
       } finally {
         // log exception if an exception occurred and was not handled
         if (message.getException() != null) {