import org.junit.Before;\r
import org.junit.Test;\r
\r
+import com.att.dmf.mr.backends.memory.MemoryQueuePublisher;\r
+\r
\r
public class MemoryQueuePublisherTest {\r
\r
MemoryQueuePublisher publisher = new MemoryQueuePublisher(null, null);\r
\r
try {\r
- publisher.sendBatchMessage("testTopic", null);\r
+ publisher.sendBatchMessageNew("testTopic", null);\r
} catch (IOException e) {\r
// TODO Auto-generated catch block\r
e.printStackTrace();\r