diff options
| -rw-r--r-- | src/main/java/org/onap/aai/event/EventBusComponent.java | 1 | ||||
| -rw-r--r-- | src/main/java/org/onap/aai/event/EventBusConsumer.java | 2 |
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) { |