* ============LICENSE_END=========================================================
*/
-package org.openecomp.appc.adapter.messaging.dmaap;
+package org.onap.appc.adapter.messaging.dmaap;
import java.io.*;
import java.util.List;
import com.att.nsa.mr.client.MRConsumer;
import org.json.JSONObject;
-import org.openecomp.appc.adapter.messaging.dmaap.impl.DmaapUtil;
+import org.onap.appc.adapter.messaging.dmaap.impl.DmaapUtil;
import com.att.nsa.mr.client.MRBatchingPublisher;
import com.att.nsa.mr.client.MRClientFactory;
int i=0;
- String topicProducerPropFileName = DmaapUtil.createProducerPropFile("org.openecomp.appc.UNIT-TEST", null);
+ String topicProducerPropFileName = DmaapUtil.createProducerPropFile("org.onap.appc.UNIT-TEST", null);
while (i< msgCount)
{
publisher.publishMessage(topicProducerPropFileName,i);
try
{
- String topic = "org.openecomp.appc.UNIT-TEST";
+ String topic = "org.onap.appc.UNIT-TEST";
Properties props = new Properties();
props.put("id", "1");
props.put("group", "group1");