lywsvip/hsweb-framework
1
0
Fork 0
mirror of https://github.com/hs-web/hsweb-framework.git synced 2026-06-20 02:47:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: 增加afterCommit模版方法

Browse Source
This commit is contained in:
zhouhao
2024-08-14 18:16:38 +08:00
parent b1ad201dd6
commit 050ea03ed5
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/utils/TransactionUtils.java
View File

@@ -1,5 +1,6 @@
package org.hswebframework.web.crud.utils;
import lombok.NonNull;
import lombok.extern.slf4j.Slf4j;
import org.springframework.transaction.NoTransactionException;
import org.springframework.transaction.reactive.TransactionContextManager;
@@ -12,6 +13,19 @@ import java.util.function.Function;
@Slf4j
public class TransactionUtils {
public static Mono<Void> afterCommit(Mono<Void> task) {
return TransactionUtils.registerSynchronization(
new TransactionSynchronization() {
@Override
@NonNull
public Mono<Void> afterCommit() {
return task;
}
},
TransactionSynchronization::afterCommit
);
}
public static Mono<Void> registerSynchronization(TransactionSynchronization synchronization,
Function<TransactionSynchronization, Mono<Void>> whenNoTransaction) {
return TransactionSynchronizationManager