0001717: IReloadListener should be passed the current loadId for use

JumpMind · May 9, 2014 · 2011496 · 2011496
1 parent 10e9607
commit 2011496
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/integrate/RunSqlReloadListener.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/integrate/RunSqlReloadListener.java
@@ -35,15 +35,15 @@ public class RunSqlReloadListener implements IReloadListener, ISymmetricEngineAw
 
     private String sqlToRunAtTargetAfterReload;
 
-    public void afterReload(ISqlTransaction transaction, Node node) {
+    public void afterReload(ISqlTransaction transaction, Node node, long loadId) {
         if (StringUtils.isNotBlank(sqlToRunAtTargetAfterReload)) {
-            engine.getDataService().insertSqlEvent(transaction, node, sqlToRunAtTargetAfterReload, true, -1, null);
+            engine.getDataService().insertSqlEvent(transaction, node, sqlToRunAtTargetAfterReload, true, loadId, null);
         }
     }
 
-    public void beforeReload(ISqlTransaction transaction, Node node) {
+    public void beforeReload(ISqlTransaction transaction, Node node, long loadId) {
         if (StringUtils.isNotBlank(sqlToRunAtTargetBeforeReload)) {
-            engine.getDataService().insertSqlEvent(transaction, node, sqlToRunAtTargetBeforeReload, true, -1, null);
+            engine.getDataService().insertSqlEvent(transaction, node, sqlToRunAtTargetBeforeReload, true, loadId, null);
         }
     }