@Test
public void testLogWithHeartbeatFiltering() throws Exception {

    setUpJdbcLog(false, null);
    assertEquals(0, getRowCount(connection, "messages_log"));
    log.onIncoming("INCOMING\00135=0\001");
    assertEquals(1, getRowCount(connection, "messages_log"));
    log.onOutgoing("OUTGOING\00135=0\001");
    assertEquals(2, getRowCount(connection, log.getOutgoingMessagesTableName()));
    setUpJdbcLog(true, null);
    assertEquals(0, getRowCount(connection, "messages_log"));
    log.onIncoming("INCOMING\00135=0\001");
    assertEquals(0, getRowCount(connection, "messages_log"));
    log.onOutgoing("OUTGOING\00135=0\001");
    assertEquals(0, getRowCount(connection, log.getOutgoingMessagesTableName()));
}