diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/config/ITableResolver.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/config/ITableResolver.java index e124d7a552..813f6458dd 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/config/ITableResolver.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/config/ITableResolver.java @@ -11,5 +11,5 @@ public interface ITableResolver extends IExtensionPoint { public void resolve(String catalog, String schema, Set tables, IDatabasePlatform platform, - INodeService nodeService, Trigger trigger); + INodeService nodeService, Trigger trigger, boolean useTableCache); } 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 c5a6a22f8d..01f1cd9d52 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 @@ -1543,7 +1543,7 @@ protected Set
getTablesForTrigger(Trigger trigger, List triggers } else if (!trigger.getSourceTableName().startsWith(parameterService.getTablePrefix() + "_") && CollectionUtils.isNotEmpty(extensionService.getExtensionPointList(ITableResolver.class))) { for (ITableResolver resolver : extensionService.getExtensionPointList(ITableResolver.class)) { - resolver.resolve(catalogName, schemaName, tables, sourcePlatform, nodeService, trigger); + resolver.resolve(catalogName, schemaName, tables, sourcePlatform, nodeService, trigger, useTableCache); } } else { Table table = sourcePlatform.getTableFromCache(