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 2382d947dd..2bd30b96e6 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 @@ -278,6 +278,16 @@ protected List buildTriggersForSymmetricTables(String version, List triggers = new ArrayList(); List tables = new ArrayList(TableConstants.getConfigTables(symmetricDialect .getTablePrefix())); + + List definedTriggers = getTriggers(); + for (Trigger trigger : definedTriggers) { + if (tables.remove(trigger.getSourceTableName())) { + log.info("Not generating virtual triggers for {} because there is a trigger already defined for it", + trigger.getSourceTableName()); + } + } + + if (extraConfigTables != null) { for (String extraTable : extraConfigTables) { tables.add(extraTable);