0001853: Clear staging if transformation changes come through the dat…

…a loader or data router
JumpMind · Jul 31, 2014 · 48b2ca2 · 48b2ca2
1 parent 9f80f58
commit 48b2ca2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/...e/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java b/...e/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java
@@ -314,6 +314,8 @@ public void batchCommitted(DataContext context) {
         if (context.get(CTX_KEY_FLUSH_TRANSFORMS_NEEDED) != null) {
             log.info("About to refresh the cache of transformation because new configuration came through the data loader");
             engine.getTransformService().clearCache();
+            log.info("About to clear the staging area because new transform configuration came through the data loader");
+            engine.getStagingManager().clean(0);
             context.remove(CTX_KEY_FLUSH_TRANSFORMS_NEEDED);
         }
 

diff --git a/...etric-core/src/main/java/org/jumpmind/symmetric/route/ConfigurationChangedDataRouter.java b/...etric-core/src/main/java/org/jumpmind/symmetric/route/ConfigurationChangedDataRouter.java
@@ -470,6 +470,9 @@ public void contextCommitted(SimpleRouterContext routingContext) {
             if (routingContext.get(CTX_KEY_FLUSH_TRANSFORMS_NEEDED) != null) {
                 log.info("About to refresh the cache of transformation because new configuration came through the data router");
                 engine.getTransformService().clearCache();
+                log.info("About to clear the staging area because new transform configuration came through the data router");
+                engine.getStagingManager().clean(0);
+
             }
 
             if (routingContext.get(CTX_KEY_FLUSH_CONFLICTS_NEEDED) != null) {