0001278: The IDatabaseWriterFilter should always be passed the source…

… table, not the target table
JumpMind · Jun 13, 2013 · 08092ee · 08092ee
1 parent ebd5e3d
commit 08092ee
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DatabaseWriter.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DatabaseWriter.java
@@ -368,8 +368,7 @@ protected boolean filterBefore(CsvData data) {
             try {
                 statistics.get(batch).startTimer(DataWriterStatisticConstants.FILTERMILLIS);
                 for (IDatabaseWriterFilter filter : filters) {
-                    process &= filter.beforeWrite(this.context,
-                            this.targetTable != null ? this.targetTable : this.sourceTable, data);
+                    process &= filter.beforeWrite(this.context, this.sourceTable, data);
                 }
             } finally {
                 statistics.get(batch).stopTimer(DataWriterStatisticConstants.FILTERMILLIS);
@@ -440,8 +439,7 @@ protected void filterAfter(CsvData data) {
             try {
                 statistics.get(batch).startTimer(DataWriterStatisticConstants.FILTERMILLIS);
                 for (IDatabaseWriterFilter filter : filters) {
-                    filter.afterWrite(this.context, this.targetTable != null ? this.targetTable
-                            : this.sourceTable, data);
+                    filter.afterWrite(this.context, this.sourceTable, data);
                 }
             } finally {
                 statistics.get(batch).stopTimer(DataWriterStatisticConstants.FILTERMILLIS);