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 {
import java.util.List;
import java.util.Properties;
import java.util.concurrent.TimeUnit;
-
+import org.onap.dmaap.mr.client.impl.MRSimplerBatchPublisher;
+import org.onap.dmaap.mr.test.clients.ProtocolTypeConstants;
import org.onap.policy.common.logging.eelf.PolicyLogger;
import org.onap.policy.common.logging.flexlogger.FlexLogger;
import org.onap.policy.common.logging.flexlogger.Logger;
-import com.att.nsa.mr.client.impl.MRSimplerBatchPublisher;
-import com.att.nsa.mr.test.clients.ProtocolTypeConstants;
-
public interface BusPublisher {
/**
import java.util.Arrays;
import org.junit.Test;
+import org.onap.dmaap.mr.client.MRClient.MRApiException;
import org.onap.policy.utils.BusConsumer;
import org.onap.policy.utils.BusPublisher;
-import com.att.nsa.mr.client.MRClient.MRApiException;
-
public class BusTest {
@Test