1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/org/onap/aai/event/AbstractEventBusEndpoint.java b/src/main/java/org/onap/aai/event/AbstractEventBusEndpoint.java
index 9a5abee..7295a9a 100644
--- a/src/main/java/org/onap/aai/event/AbstractEventBusEndpoint.java
+++ b/src/main/java/org/onap/aai/event/AbstractEventBusEndpoint.java
@@ -21,7 +21,7 @@
 package org.onap.aai.event;
 
 import org.apache.camel.Component;
-import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.support.DefaultEndpoint;
 
 public abstract class AbstractEventBusEndpoint extends DefaultEndpoint {
 
@@ -29,7 +29,7 @@ public abstract class AbstractEventBusEndpoint extends DefaultEndpoint {
     super(endpointUri, component);
   }
 
-  abstract void close() throws Exception;
+  abstract void end() throws Exception;
   abstract int getPollingDelay();
   abstract int getPoolSize();
   abstract String getEventTopic();