Skip to content

Commit c20a117

Browse files
meepownDavideD
authored andcommitted
[#1362] override clear() to clear reactiveActionQueue
1 parent cca3d5a commit c20a117

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveSessionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1601,6 +1601,12 @@ public CompletionStage<Void> reactiveRemoveOrphanBeforeUpdates(String entityName
16011601
});
16021602
}
16031603

1604+
@Override
1605+
public void clear() {
1606+
super.clear();
1607+
this.reactiveActionQueue.clear();
1608+
}
1609+
16041610
private void logRemoveOrphanBeforeUpdates(String timing, String entityName, Object entity, StatefulPersistenceContext persistenceContext) {
16051611
if ( log.isTraceEnabled() ) {
16061612
final EntityEntry entityEntry = persistenceContext.getEntry( entity );

0 commit comments

Comments
 (0)