diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java index 9728e46362..012da12e6a 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/AuditTableDataRouter.java @@ -97,7 +97,7 @@ public Set routeToNodes(SimpleRouterContext context, DataMetaData dataMe Long sequence = (Long) context.get(auditTableName); if (sequence == null) { sequence = 1l + template.queryForLong(String.format("select max(%s) from %s", - COLUMN_AUDIT_ID, auditTableName)); + table.getColumnWithName(COLUMN_AUDIT_ID).getName(), auditTableName)); } else { sequence = 1l + sequence; }