0003335: Extension point during reloads to adjust the active trigger

histories
JumpMind · Dec 13, 2017 · 4da3bf6 · 4da3bf6
1 parent ec29942
commit 4da3bf6
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/DefaultReloadGenerator.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/DefaultReloadGenerator.java
@@ -9,13 +9,14 @@
 
 public class DefaultReloadGenerator implements IReloadGenerator, IBuiltInExtensionPoint {
 
+    public static final String NAME = "default reload generator";
+
     ISymmetricEngine engine;
 
-    @Override
-    public void setSymmetricEngine(ISymmetricEngine engine) {
+    public DefaultReloadGenerator(ISymmetricEngine engine) {
         this.engine = engine;
     }
-
+    
     @Override
     public List<TriggerHistory> getActiveTriggerHistories(Node targetNode) {
         return engine.getTriggerRouterService().getActiveTriggerHistories();

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/IReloadGenerator.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/IReloadGenerator.java
@@ -3,11 +3,10 @@
 import java.util.List;
 
 import org.jumpmind.extension.IExtensionPoint;
-import org.jumpmind.symmetric.ext.ISymmetricEngineAware;
 import org.jumpmind.symmetric.model.Node;
 import org.jumpmind.symmetric.model.TriggerHistory;
 
-public interface IReloadGenerator extends IExtensionPoint, ISymmetricEngineAware {
+public interface IReloadGenerator extends IExtensionPoint {
 
     List<TriggerHistory> getActiveTriggerHistories(Node targetNode);
 }
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java
@@ -47,6 +47,7 @@
 import org.jumpmind.symmetric.common.Constants;
 import org.jumpmind.symmetric.common.ParameterConstants;
 import org.jumpmind.symmetric.io.data.DataEventType;
+import org.jumpmind.symmetric.load.DefaultReloadGenerator;
 import org.jumpmind.symmetric.load.IReloadGenerator;
 import org.jumpmind.symmetric.model.Channel;
 import org.jumpmind.symmetric.model.Data;
@@ -144,7 +145,7 @@ public RouterService(ISymmetricEngine engine) {
                 engine.getSymmetricDialect()));
         extensionService.addExtensionPoint(FileSyncDataRouter.ROUTER_TYPE, new FileSyncDataRouter(engine));
         extensionService.addExtensionPoint("dbf", new DBFRouter(engine));
-
+        extensionService.addExtensionPoint(DefaultReloadGenerator.NAME, new DefaultReloadGenerator(engine));
         setSqlMap(new RouterServiceSqlMap(symmetricDialect.getPlatform(),
                 createSqlReplacementTokens()));   
     }