JdbcLog extends AbstractLog { public String getOutgoingMessagesTableName() { return outgoingMessagesTableName; } JdbcLog(SessionSettings settings, SessionID sessionID, DataSource ds); void onEvent(String value); void clear(); String getIncomingMessagesTableName(); String getOutgoingMessagesTableName(); String getEventTableName(); void onErrorEvent(String text);  }
@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())); }