diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ITriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ITriggerRouterService.java
index 9399bda5de..f0fe94bfdb 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ITriggerRouterService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/ITriggerRouterService.java
@@ -153,7 +153,9 @@ public TriggerHistory getNewestTriggerHistoryForTrigger(String triggerId, String
 
     public Map<Long, TriggerHistory> getHistoryRecords();
 
-    public void deleteTriggerRouter(TriggerRouter triggerRouter);
+    public void deleteTriggerRouter(TriggerRouter triggerRouter);
+    
+    public void deleteTriggerRouter(String triggerId, String routerId);
     
     public void saveTriggerRouter(TriggerRouter triggerRouter, boolean updateTriggerRouterTableOnly);
     
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java
index afda184c4b..33bb29ee96 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java
@@ -910,6 +910,12 @@ public void insert(TriggerHistory newHistRecord) {
                         Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.BIGINT, Types.BIGINT,
                         Types.VARCHAR });
     }
+    
+    @Override
+    public void deleteTriggerRouter(String triggerId, String routerId) {
+        sqlTemplate.update(getSql("deleteTriggerRouterSql"), triggerId, routerId);
+        clearCache();
+    }
 
     public void deleteTriggerRouter(TriggerRouter triggerRouter) {
         sqlTemplate.update(getSql("deleteTriggerRouterSql"), (Object) triggerRouter.getTrigger()