assertLoggedMessage(connection, sessionID, "incoming", systemTime, inmsg); assertLoggedMessage(connection, sessionID, "outgoing", systemTime, outmsg);
assertLoggedMessage(connection, sessionID, "messages", systemTime, inmsg); assertLoggedMessage(connection, sessionID, "messages", systemTime, outmsg);
    public void testLog() throws Exception {    	if (!MySQLTestSupport.isMySQLAvailable(getConfigurationFileName())) {    		return;    	}        long systemTime = System.currentTimeMillis();        SystemTime.setTimeSource(new MockSystemTimeSource(systemTime));        SessionID sessionID = new SessionID("FIX.4.2", "SENDER" + System.currentTimeMillis(),                "TARGET" + System.currentTimeMillis(), "X");        SessionSettings settings = new SessionSettings("test/test.cfg");        MySQLLogFactory factory = new MySQLLogFactory(settings);        Log log = factory.create(sessionID);        assertEquals(MySQLLog.class, log.getClass());        String inmsg = "IN"+System.currentTimeMillis();        String outmsg = "OUT"+System.currentTimeMillis();        String eventmsg = "EVENT"+System.currentTimeMillis();                log.onIncoming(inmsg);        log.onOutgoing(outmsg);        log.onEvent(eventmsg);        Connection connection = null;        try {            connection = JdbcUtil.openMySQLStoreConnection(settings, sessionID);            assertLoggedMessage(connection, sessionID, "incoming", systemTime, inmsg);            assertLoggedMessage(connection, sessionID, "outgoing", systemTime, outmsg);            assertLoggedMessage(connection, sessionID, "event", systemTime, eventmsg);        } finally {            if (connection != null) {                connection.close();            }        }    }