From bce0f20270d57c20764f27b93bc3aa65ac5d33ca Mon Sep 17 00:00:00 2001 From: Catherine Quamme Date: Mon, 10 Apr 2023 10:56:08 -0400 Subject: [PATCH] 0005741: Java router code assistance --- .../main/java/org/jumpmind/symmetric/route/JavaDataRouter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/JavaDataRouter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/JavaDataRouter.java index 7fb451101b..0589dcbbf3 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/JavaDataRouter.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/JavaDataRouter.java @@ -25,6 +25,7 @@ import org.jumpmind.extension.IBuiltInExtensionPoint; import org.jumpmind.symmetric.ISymmetricEngine; +import org.jumpmind.symmetric.db.ISymmetricDialect; import org.jumpmind.symmetric.model.DataMetaData; import org.jumpmind.symmetric.model.Node; import org.jumpmind.symmetric.model.Router; @@ -44,10 +45,12 @@ public class JavaDataRouter extends AbstractDataRouter implements IBuiltInExtens + " boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter) {\n\n"; public final static String CODE_END = "\n\n }\n}\n"; protected ISymmetricEngine engine; + protected ISymmetricDialect dialect; protected final String ROUTER_KEY = String.format("%d.JavaRouter", hashCode()); public JavaDataRouter(ISymmetricEngine engine) { this.engine = engine; + this.dialect = engine.getSymmetricDialect(); } public Set routeToNodes(SimpleRouterContext context, DataMetaData dataMetaData, Set nodes,