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 index 5c5f7ecb54..a9729809a5 100644 --- 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 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 index 33dd8e7bdf..52eb278c34 100644 --- 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 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 index f3b462c9f9..d8a97798c2 100644 --- 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())); }