github/ebean
4
0
Fork 0
mirror of https://github.com/ebean-orm/ebean.git synced 2024-04-21 10:51:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

#1431 - Refactor internals for RemoteTransactionEvent binary serialisation

Browse Source
This commit is contained in:
rob bygrave
2018-06-17 23:29:11 +12:00
parent e1d4159453
commit bf33b3f96f
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/io/ebeaninternal/server/transaction/PostCommitProcessing.java
+3 -6
View File
@@ -169,7 +169,9 @@ final class PostCommitProcessing {
Set<String> 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<String> 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);