import org.junit.Test;\r
\r
import com.att.ajsc.filemonitor.AJSCPropertiesMap;\r
-import com.att.nsa.cambria.backends.Publisher.message;\r
+import com.att.dmf.mr.backends.Publisher.message;\r
import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;\r
\r
import kafka.common.FailedToSendMessageException;\r