From 2011496b39c3c66852c27ae57bb8fa94ed2e3dc2 Mon Sep 17 00:00:00 2001 From: chenson42 Date: Fri, 9 May 2014 19:18:21 +0000 Subject: [PATCH] 0001717: IReloadListener should be passed the current loadId for use --- .../symmetric/integrate/RunSqlReloadListener.java | 8 ++++---- 1 file changed, 4 insertions(+), 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 index b724e0f135..47ea2f078f 100644 --- 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); } }