fix inserting create table events under phantom channel in data servi…

…ce (#161)
JumpMind · Jun 21, 2021 · 46c277e · 46c277e
1 parent efebb47
commit 46c277e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -1299,7 +1299,7 @@ private int insertCreateBatchesForReload(Node targetNode, long loadId, String cr
                     if (currentRequest != null && currentRequest.isCreateTable()
                             && engine.getGroupletService().isTargetEnabled(triggerRouter,
                                     targetNode)) {
-                        insertCreateEvent(transaction, targetNode, triggerHistory, triggerRouter.getRouter().getRouterId(), true,
+                        insertCreateEvent(transaction, targetNode, triggerHistory, triggerRouter.getTrigger().getReloadChannelId(), true,
                                 loadId, createBy, false, false, false);
                         createEventsSent++;
                         if (!transactional) {