Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 10b32f8

Browse files
committedJan 24, 2025··
fix
1 parent 4d2b604 commit 10b32f8

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed
 

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ private void threadCheck() {
189189
}
190190

191191
@Override
192-
protected StatefulPersistenceContext createPersistenceContext() {
192+
protected PersistenceContext createPersistenceContext() {
193193
return new ReactivePersistenceContextAdapter( this );
194194
}
195195

@@ -1700,14 +1700,14 @@ public void checkOpen() {
17001700

17011701
@Override
17021702
public void removeOrphanBeforeUpdates(String entityName, Object child) {
1703-
throw new UnsupportedOperationException();
1703+
throw LOG.nonReactiveMethodCall( "reactiveRemoveOrphanBeforeUpdates" );
17041704
}
17051705

17061706
@Override
17071707
public CompletionStage<Void> reactiveRemoveOrphanBeforeUpdates(String entityName, Object child) {
17081708
// TODO: The removeOrphan concept is a temporary "hack" for HHH-6484. This should be removed once action/task
17091709
// ordering is improved.
1710-
final StatefulPersistenceContext persistenceContext = (StatefulPersistenceContext) getPersistenceContextInternal();
1710+
final PersistenceContext persistenceContext = getPersistenceContextInternal();
17111711
persistenceContext.beginRemoveOrphanBeforeUpdates();
17121712
return fireRemove( new DeleteEvent( entityName, child, false, true, this ) )
17131713
.thenAccept( v -> {
@@ -1728,7 +1728,7 @@ private void logRemoveOrphanBeforeUpdates(
17281728
String timing,
17291729
String entityName,
17301730
Object entity,
1731-
StatefulPersistenceContext persistenceContext) {
1731+
PersistenceContext persistenceContext) {
17321732
if ( LOG.isTraceEnabled() ) {
17331733
final EntityEntry entityEntry = persistenceContext.getEntry( entity );
17341734
LOG.tracef(

0 commit comments

Comments
 (0)
Please sign in to comment.