0003056: Make XmlPublisherDatabaseWriterFilter configurable to publish

either on batch complete or batch commit
JumpMind · Apr 14, 2017 · f7b4989 · f7b4989
1 parent e1555f8
commit f7b4989
Showing 1 changed file with 29 additions and 10 deletions.
diff --git a/...rver/src/main/java/org/jumpmind/symmetric/integrate/XmlPublisherDatabaseWriterFilter.java b/...rver/src/main/java/org/jumpmind/symmetric/integrate/XmlPublisherDatabaseWriterFilter.java
@@ -62,9 +62,15 @@
  * </pre>
  */
 public class XmlPublisherDatabaseWriterFilter extends AbstractXmlPublisherExtensionPoint implements
-        IPublisherFilter, INodeGroupExtensionPoint {
+        IPublisherFilter, INodeGroupExtensionPoint {
+
+    public static final String PUBLISH_ON_COMPLETE = "COMPLETE";
+
+    public static final String PUBLISH_ON_COMMIT = "COMMIT";
 
-    protected boolean loadDataInTargetDatabase = true;
+    protected boolean loadDataInTargetDatabase = true;
+
+    protected String publishOn = PUBLISH_ON_COMPLETE;
 
     public boolean beforeWrite(
             DataContext context, Table table, CsvData data) {
@@ -87,15 +93,12 @@ public boolean beforeWrite(
         return loadDataInTargetDatabase;
     }
 
-    public void batchComplete(
-            DataContext context) {
-        if (doesXmlExistToPublish(context)) {
-            finalizeXmlAndPublish(context);
-        }
-    }
-
     public void setLoadDataInTargetDatabase(boolean loadDataInTargetDatabase) {
         this.loadDataInTargetDatabase = loadDataInTargetDatabase;
+    }
+
+    public void setPublishOn(String publishOn) {
+        this.publishOn = publishOn;
     }
 
     public void afterWrite(
@@ -110,9 +113,25 @@ public boolean handlesMissingTable(
     public void earlyCommit(
             DataContext context) {
     }
+
+    public void batchComplete(
+            DataContext context) {
+        if (PUBLISH_ON_COMPLETE.equals(publishOn)) {
+            publish(context);
+        }
+    }
 
     public void batchCommitted(
-            DataContext context) {
+            DataContext context) {
+        if (PUBLISH_ON_COMMIT.equals(publishOn)) {
+            publish(context);
+        }
+    }
+
+    private void publish(DataContext context) {
+        if (doesXmlExistToPublish(context)) {
+            finalizeXmlAndPublish(context);
+        }                
     }
 
     public void batchRolledback(