diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/SymmetricEngine.java b/symmetric/src/main/java/org/jumpmind/symmetric/SymmetricEngine.java index c8e09866be..f19258e7e7 100644 --- a/symmetric/src/main/java/org/jumpmind/symmetric/SymmetricEngine.java +++ b/symmetric/src/main/java/org/jumpmind/symmetric/SymmetricEngine.java @@ -338,6 +338,10 @@ public String reloadNode(String nodeId) { return dataService.reloadNode(nodeId); } + public String sendSQL(String nodeId, String tableName, String sql) { + return dataService.sendSQL(nodeId, tableName, sql); + } + /** * This can be called if the push job has not been enabled. It will perform * a push the same way the {@link PushJob} would have. @@ -408,6 +412,10 @@ public void openRegistration(String groupId, String externalId) { registrationService.openRegistration(groupId, externalId); } + public void reOpenRegistration(String nodeId) { + registrationService.reOpenRegistration(nodeId); + } + /** * Check to see if this node has been registered. *