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 {
- public AbstractEventBusEndpoint() {
- }
public AbstractEventBusEndpoint(String endpointUri, Component component) {
super(endpointUri, component);
}
- public AbstractEventBusEndpoint(String endpointUri) {
- super(endpointUri);
- }
-
- abstract void close();
+ abstract void end() throws Exception;
abstract int getPollingDelay();
abstract int getPoolSize();
abstract String getEventTopic();