package journal.action; import journal.reader.DataJournalEntry; import journal.reader.JournalEntry; public class OpenAndHaveFilter extends BaseFilter { private boolean passThrough(JournalEntry entry) { DataJournalEntry dataEntry = (DataJournalEntry) entry; String tableName = dataEntry.getTableName(); if (tableName.equals("db.have") || tableName.equals("db.working") || tableName.equals("db.locks") || tableName.equals("db.resolve") || tableName.equals("db.resolved")) { return false; } return true; } @Override public void putValue(JournalEntry entry) throws Exception { if (passThrough(entry)) { nextAction.putValue(entry); } } @Override public void replaceValue(JournalEntry entry) throws Exception { if (passThrough(entry)) { nextAction.replaceValue(entry); } } @Override public void deleteValue(JournalEntry entry) throws Exception { if (passThrough(entry)) { nextAction.deleteValue(entry); } } }
# | Change | User | Description | Committed | |
---|---|---|---|---|---|
#2 | 8024 | Sven Erik Knop | Refactoring: moved the filter into their own package | ||
#1 | 7527 | Sven Erik Knop |
JournalReader, now in its proper place. Documentation to follow. |