@Test
public void testQuery() {

    connectToSource(srcName, null);
    
    Map<String,Object> queryMessage = new LinkedHashMap<>();
    String key = "query";
    String val = "request";
    queryMessage.put(key, val);
    
    ResponseBody body = TestListener.createQueryMessage(queryMessage, srcName);
    listener.onMessage(body);
    
    assert qHandler.compareOp(ExtensionServiceMessage.OP_QUERY);
    assert qHandler.compareSourceName( srcName);
    assert qHandler.compareValue(key, val);
}