@Test
public void testIncorrectQueryRequests() {        

    Map<String, Object> request;
    ExtensionServiceMessage msg = new ExtensionServiceMessage("");
    Map<String, String> header = new LinkedHashMap<>();
    header.put(ExtensionServiceMessage.ORIGIN_ADDRESS_HEADER, "queryAddress");
    msg.messageHeaders = header;
    
    // Sending empty query request
    request = new LinkedHashMap<>();
    msg.object = request;
    core.readQueueMessage(msg);
    assertFalse("Core should not be closed", core.isClosed());
    
    // Sending jibberish as query request
    request = new LinkedHashMap<>();
    request.put("query", "jibberish");
    msg.object = request;
    core.readQueueMessage(msg);
    assertFalse("Core should not be closed", core.isClosed());
}