sync triggers if a create comes through

JumpMind · Apr 27, 2012 · 6c4e9be · 6c4e9be
1 parent 730d5fd
commit 6c4e9be
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/.../symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedFilter.java b/.../symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedFilter.java
@@ -27,8 +27,7 @@
 import org.jumpmind.symmetric.common.TableConstants;
 import org.jumpmind.symmetric.io.data.CsvData;
 import org.jumpmind.symmetric.io.data.DataContext;
-import org.jumpmind.symmetric.io.data.IDataReader;
-import org.jumpmind.symmetric.io.data.IDataWriter;
+import org.jumpmind.symmetric.io.data.DataEventType;
 import org.jumpmind.symmetric.io.data.writer.DatabaseWriterFilterAdapter;
 import org.jumpmind.symmetric.service.IConfigurationService;
 import org.jumpmind.symmetric.service.IParameterService;
@@ -76,14 +75,14 @@ public ConfigurationChangedFilter(IParameterService parameterService,
     @Override
     public void afterWrite(
             DataContext context, Table table, CsvData data) {
-        recordSyncNeeded(context, table);
+        recordSyncNeeded(context, table, data);
         recordChannelFlushNeeded(context, table);
         recordTransformFlushNeeded(context, table);
     }
 
     private void recordSyncNeeded(
-            DataContext context, Table table) {
-        if (isSyncTriggersNeeded(table)) {
+            DataContext context, Table table, CsvData data) {
+        if (isSyncTriggersNeeded(table) || data.getDataEventType() == DataEventType.CREATE) {
             context.put(CTX_KEY_RESYNC_NEEDED, true);
         }
     }