Merge "Local and Class variable name conflict resolved"

[policy/engine.git] / PolicyEngineUtils / src / main / java / org / onap / policy / utils / BusConsumer.java

diff --git a/PolicyEngineUtils/src/main/java/org/onap/policy/utils/BusConsumer.java b/PolicyEngineUtils/src/main/java/org/onap/policy/utils/BusConsumer.java
index 1b31394..6d80a6a 100644 (file)
--- a/PolicyEngineUtils/src/main/java/org/onap/policy/utils/BusConsumer.java
+++ b/PolicyEngineUtils/src/main/java/org/onap/policy/utils/BusConsumer.java
@@ -70,7 +70,7 @@ public interface BusConsumer {
                public DmaapConsumerWrapper(List<String> servers, String topic, 
                                                                String aafLogin, String aafPassword,
                                                                String consumerGroup, String consumerInstance,
-                                                               int fetchTimeout, int fetchLimit)  throws MalformedURLException{
+                                                               int fetchTimeout, int fetchLimit) throws MalformedURLException{
                                        
                        this.consumer = new MRConsumerImpl(servers, topic, 
                                                                                           consumerGroup, consumerInstance, 
@@ -91,6 +91,7 @@ public interface BusConsumer {
                /**
                 * {@inheritDoc}
                 */
+               @Override
                public Iterable<String> fetch() throws MRApiException {
                        try {
                 return this.consumer.fetch();
@@ -102,6 +103,7 @@ public interface BusConsumer {
                /**
                 * {@inheritDoc}
                 */
+               @Override
                public void close() {
                        this.consumer.close();
                }