@Test
public void testPublishQuery() throws VantiqSQLException {

    assumeTrue(testDBUsername != null && testDBPassword != null && testDBURL != null && jdbcDriverLoc != null);
    jdbc.setupJDBC(testDBURL, testDBUsername, testDBPassword, false, 0);
    
    Map<String, Object> request;
    ExtensionServiceMessage msg = new ExtensionServiceMessage("");
    Map<String, String> header = new LinkedHashMap<>();
    header.put(ExtensionServiceMessage.ORIGIN_ADDRESS_HEADER, "queryAddress");
    msg.messageHeaders = header;
    
    request = new LinkedHashMap<>();
    msg.object = request;
    core.executePublish(msg);
    assertFalse("Core should not be closed", core.isClosed());
    
    request = new LinkedHashMap<>();
    request.put("query", "jibberish");
    msg.object = request;
    core.executePublish(msg);
    assertFalse("Core should not be closed", core.isClosed());
}