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 02c97e3e86..eb0506d562 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
@@ -269,10 +269,10 @@ protected void insertInitialLoadEvents() {
 
                         
                         for (NodeSecurity security : nodeSecurities) {
-                            List<TriggerHistory> activeHistories = triggerRouterService.getActiveTriggerHistories();
+                        		Node targetNode = engine.getNodeService().findNode(security.getNodeId());
+                            List<TriggerHistory> activeHistories = extensionService.getExtensionPoint(IReloadGenerator.class).getActiveTriggerHistories(targetNode);
                             
                             if (activeHistories.size() > 0) {
-                                Node targetNode = engine.getNodeService().findNode(security.getNodeId());
                                 boolean thisMySecurityRecord = security.getNodeId().equals(
                                         identity.getNodeId());
                                 boolean reverseLoadQueued = security.isRevInitialLoadEnabled();