From 6c4e9bea0d3caa34f36faa2fe2e5d0b43cd09322 Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Fri, 27 Apr 2012 12:15:09 +0000
Subject: [PATCH] sync triggers if a create comes through

---
 .../symmetric/load/ConfigurationChangedFilter.java       | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedFilter.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedFilter.java
index 27296280cb..a54162615e 100644
--- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedFilter.java
+++ b/symmetric/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);
         }
     }