@Test
public void testPublish() {

    connectToSource(srcName, null);
    
    Map<String,Object> publishMessage = new LinkedHashMap<>();
    String key = "publish";
    String val = "info";
    publishMessage.put(key, val);
    
    ResponseBody body = TestListener.createPublishMessage(publishMessage, srcName);
    listener.onMessage(body);
    
    assert pHandler.compareOp(ExtensionServiceMessage.OP_PUBLISH);
    assert pHandler.compareSourceName(srcName);
    assert pHandler.compareValue( key, val);
}