aboutsummaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/org/onap/aai/event/EventBusComponent.java1
-rw-r--r--src/main/java/org/onap/aai/event/EventBusConsumer.java2
2 files changed, 2 insertions, 1 deletions
diff --git a/src/main/java/org/onap/aai/event/EventBusComponent.java b/src/main/java/org/onap/aai/event/EventBusComponent.java
index f6e373a..fdcc85d 100644
--- a/src/main/java/org/onap/aai/event/EventBusComponent.java
+++ b/src/main/java/org/onap/aai/event/EventBusComponent.java
@@ -41,6 +41,7 @@ public class EventBusComponent extends UriEndpointComponent {
super(context, EventBusEndpoint.class);
}
+ @Override
protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters)
throws Exception {
Endpoint endpoint = new EventBusEndpoint(uri, this);
diff --git a/src/main/java/org/onap/aai/event/EventBusConsumer.java b/src/main/java/org/onap/aai/event/EventBusConsumer.java
index df76fa2..ed28571 100644
--- a/src/main/java/org/onap/aai/event/EventBusConsumer.java
+++ b/src/main/java/org/onap/aai/event/EventBusConsumer.java
@@ -120,7 +120,7 @@ public class EventBusConsumer extends ScheduledPollConsumer {
}
return processCount;
}
-
+ @Override
protected void doStop() throws Exception {
super.doStop();
if (consumer != null) {