Update apache camel from 2.x to 3.x

[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 da8ffb5..bc698df 100644 (file)
--- a/src/main/java/org/onap/aai/event/EventBusConsumer.java
+++ b/src/main/java/org/onap/aai/event/EventBusConsumer.java
@@ -25,13 +25,12 @@ import org.onap.aai.event.api.EventConsumer;
 import org.apache.camel.Exchange;
 import org.apache.camel.Message;
 import org.apache.camel.Processor;
-import org.apache.camel.impl.ScheduledPollConsumer;
+import org.apache.camel.support.ScheduledPollConsumer;
 import org.onap.aai.logging.RouterCoreMsgs;
 import org.onap.aai.cl.api.Logger;
 import org.onap.aai.cl.eelf.LoggerFactory;
 import org.onap.aai.cl.mdc.MdcContext;
 
-import java.util.Collections;
 import java.util.UUID;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
 
@@ -97,14 +96,14 @@ public class EventBusConsumer extends ScheduledPollConsumer {
   protected void doStop() throws Exception {
     super.doStop();
     if (endpoint != null) {
-      endpoint.close();
+      endpoint.end();
     }
   }
   @Override
   protected void doShutdown() throws Exception {
     super.doShutdown();
     if (endpoint != null) {
-      endpoint.close();
+      endpoint.end();
     }
   }