0003168: Create CSV Router to route data from a CSV file

JumpMind · Jul 2, 2017 · a64a044 · a64a044
1 parent a76dac8
commit a64a044
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -1882,13 +1882,14 @@ public CsvData next() {
                         TriggerHistory triggerHistory = data.getTriggerHistory();
                         Trigger trigger = triggerRouterService.getTriggerById(
                                 triggerHistory.getTriggerId(), false);
-                        if (trigger != null || triggerHistory.getTriggerId().equals(AbstractFileParsingRouter.TRIGGER_ID_FILE_PARSER)) {
+                        boolean isFileParserRouter = triggerHistory.getTriggerId().equals(AbstractFileParsingRouter.TRIGGER_ID_FILE_PARSER);
+                        if (trigger != null || isFileParserRouter) {
                             if (lastTriggerHistory == null || lastTriggerHistory
                                     .getTriggerHistoryId() != triggerHistory.getTriggerHistoryId() || 
                                     lastRouterId == null || !lastRouterId.equals(routerId)) {
 
                                 this.sourceTable = columnsAccordingToTriggerHistory.lookup(
-                                            routerId, triggerHistory, false, false);
+                                            routerId, triggerHistory, false, !isFileParserRouter);
 
                                 this.targetTable = columnsAccordingToTriggerHistory.lookup(
                                         routerId, triggerHistory, true, false);