@Test 
public void testReconnectHandler() {

    connectToSource(srcName, null);
    
    ResponseBody body = TestListener.createReconnectMessage(srcName);
    
    listener.onMessage(body);
    
    assert !client.isConnected();
    assert rHandler.compareOp(ExtensionServiceMessage.OP_RECONNECT_REQUIRED);
}