diff --git a/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java b/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java index c84593646..9797693fb 100644 --- a/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java +++ b/src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java @@ -169,7 +169,9 @@ final class PostCommitProcessing { Set touched = cacheChanges.touchedTables(); if (touched != null && !touched.isEmpty()) { manager.processTouchedTables(touched, cacheChanges.modificationTimestamp()); - // TODO: Propagate touched tables to other cluster members + if (remoteTransactionEvent != null) { + remoteTransactionEvent.addRemoteTableMod(new RemoteTableMod(cacheChanges.modificationTimestamp(), touched)); + } } cacheChanges.apply(); } @@ -210,11 +212,6 @@ final class PostCommitProcessing { } RemoteTransactionEvent remoteTransactionEvent = new RemoteTransactionEvent(serverName); - - Set touched = cacheChanges.touchedTables(); - if (touched != null && !touched.isEmpty()) { - remoteTransactionEvent.addRemoteTableMod(new RemoteTableMod(cacheChanges.modificationTimestamp(), touched)); - } if (beanPersistIdMap != null) { for (BeanPersistIds beanPersist : beanPersistIdMap.values()) { remoteTransactionEvent.addBeanPersistIds(beanPersist);