@Test 
public void testHttp() {

    connectToSource(srcName, null);
    
    Response resp = new Response().status(200);
    ResponseBody body = TestListener.createHttpMessage(resp);
    
    listener.onMessage(body);
    
    assert hHandler.compareStatus(200);
}