Skip to content

Commit cb28d49

Browse files
committed
refactor: 增加afterCommitWithOutTransaction
1 parent 18eabee commit cb28d49

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

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

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,19 @@ public static <T> Flux<T> tryRunInTransaction(Flux<T> task, TransactionDefinitio
5151
return task;
5252
}
5353

54+
public static Mono<Void> afterCommitWithOutTransaction(Mono<Void> task) {
55+
return TransactionUtils.registerSynchronization(
56+
new TransactionSynchronization() {
57+
@Override
58+
@NonNull
59+
public Mono<Void> afterCommit() {
60+
return task;
61+
}
62+
},
63+
TransactionSynchronization::afterCommit
64+
);
65+
}
66+
5467
public static Mono<Void> afterCommit(Mono<Void> task) {
5568
return TransactionUtils.registerSynchronization(
5669
new TransactionSynchronization() {

0 commit comments

Comments
 (0)