3 files changed, 4 insertions, 4 deletions
diff --git a/src/main/java/org/onap/aai/event/EventBusConsumer.java b/src/main/java/org/onap/aai/event/EventBusConsumer.java
index ed28571..2da879d 100644
--- a/src/main/java/org/onap/aai/event/EventBusConsumer.java
+++ b/src/main/java/org/onap/aai/event/EventBusConsumer.java
@@ -127,7 +127,7 @@ public class EventBusConsumer extends ScheduledPollConsumer {
       consumer.close();
     }
   }
-
+  @Override
   protected void doShutdown() throws Exception {
     super.doShutdown();
     if (consumer != null) {
diff --git a/src/main/java/org/onap/aai/event/EventBusEndpoint.java b/src/main/java/org/onap/aai/event/EventBusEndpoint.java
index bbed74a..0b883dd 100644
--- a/src/main/java/org/onap/aai/event/EventBusEndpoint.java
+++ b/src/main/java/org/onap/aai/event/EventBusEndpoint.java
@@ -75,7 +75,7 @@ public class EventBusEndpoint extends DefaultEndpoint {
   public EventBusEndpoint(String endpointUri) {
     super(endpointUri);
   }
-
+  @Override
   public Producer createProducer() throws Exception {
     return new EventBusProducer(this);
   }
@@ -83,7 +83,7 @@ public class EventBusEndpoint extends DefaultEndpoint {
   public Consumer createConsumer(Processor processor) throws Exception {
     return new EventBusConsumer(this, processor);
   }
-
+  @Override
   public boolean isSingleton() {
     return false;
   }
diff --git a/src/main/java/org/onap/aai/event/EventBusProducer.java b/src/main/java/org/onap/aai/event/EventBusProducer.java
index a0578fc..50f6d96 100644
--- a/src/main/java/org/onap/aai/event/EventBusProducer.java
+++ b/src/main/java/org/onap/aai/event/EventBusProducer.java
@@ -35,7 +35,7 @@ public class EventBusProducer extends DefaultProducer {
     super(endpoint);
     this.endpoint = endpoint;
   }
-
+  @Override
   public void process(Exchange exchange) throws Exception {
     // Publishing to event bus is currently not supported
   }