X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=PolicyEngineUtils%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fpolicy%2Futils%2FBusConsumer.java;h=0d4c86b3d9b738b022ec60d4f06a603a232f63ec;hb=cf54241ec76e67246961eb2d25c55b1e14c43877;hp=2c867a3d1446b101cb96dba1cf6ee1917df892f7;hpb=e0385921034ae9ce860038ea65d2d13259f7cc4c;p=policy%2Fengine.git 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 2c867a3d1..0d4c86b3d 100644 --- a/PolicyEngineUtils/src/main/java/org/onap/policy/utils/BusConsumer.java +++ b/PolicyEngineUtils/src/main/java/org/onap/policy/utils/BusConsumer.java @@ -23,10 +23,9 @@ package org.onap.policy.utils; import java.net.MalformedURLException; import java.util.List; import java.util.Properties; - -import com.att.nsa.mr.client.MRClient.MRApiException; -import com.att.nsa.mr.client.impl.MRConsumerImpl; -import com.att.nsa.mr.test.clients.ProtocolTypeConstants; +import org.onap.dmaap.mr.client.MRClient.MRApiException; +import org.onap.dmaap.mr.client.impl.MRConsumerImpl; +import org.onap.dmaap.mr.test.clients.ProtocolTypeConstants; public interface BusConsumer { @@ -91,6 +90,7 @@ public interface BusConsumer { /** * {@inheritDoc} */ + @Override public Iterable fetch() throws MRApiException { try { return this.consumer.fetch(); @@ -102,6 +102,7 @@ public interface BusConsumer { /** * {@inheritDoc} */ + @Override public void close() { this.consumer.close(); }