@Test
public void testDefaultQuery() {

    listener = new ExtensionWebSocketListener(client);
    client.listener = listener;
    
    connectToSource(srcName, null);
    
    ResponseBody body = TestListener.createQueryMessage(new LinkedHashMap(), srcName);
    listener.onMessage(body);
    Response resp = null;
    try {
        resp = client.getLastMessageAsResponse();
    } catch(Exception e) { 
        e.printStackTrace();
        fail("Could not interpret the default query handler response\n");
    }
    
    assert resp.getBody() instanceof Map;
    
    Map<String,Object> m = (Map) resp.getBody();
    
    assert "io.vantiq.extjsdk.unsetQueryHandler".equals(m.get("messageCode"));
    assert m.get("messageTemplate") instanceof String;
    assert m.get("parameters") instanceof List;
}