@@ -150,7 +150,6 @@ public abstract class AbstractSharedSessionContract implements SharedSessionCont
150
150
private transient SessionFactoryImpl factory ;
151
151
private transient SessionFactoryOptions factoryOptions ;
152
152
private transient JdbcServices jdbcServices ;
153
- protected transient FastSessionServices fastSessionServices ;
154
153
155
154
private UUID sessionIdentifier ;
156
155
private Object sessionToken ;
@@ -196,7 +195,6 @@ public AbstractSharedSessionContract(SessionFactoryImpl factory, SessionCreation
196
195
this .factoryOptions = factory .getSessionFactoryOptions ();
197
196
this .jdbcServices = factory .getJdbcServices ();
198
197
199
- fastSessionServices = factory .getFastSessionServices ();
200
198
cacheTransactionSync = factory .getCache ().getRegionFactory ().createTransactionContext ( this );
201
199
flushMode = options .getInitialSessionFlushMode ();
202
200
tenantIdentifier = getTenantId ( factoryOptions , options );
@@ -234,7 +232,7 @@ public AbstractSharedSessionContract(SessionFactoryImpl factory, SessionCreation
234
232
// This must happen *after* the JdbcSessionContext was initialized,
235
233
// because some calls retrieve this context indirectly via Session getters.
236
234
jdbcCoordinator = createJdbcCoordinator ( options );
237
- transactionCoordinator = fastSessionServices . getTransactionCoordinatorBuilder ()
235
+ transactionCoordinator = factory . transactionCoordinatorBuilder
238
236
.buildTransactionCoordinator ( jdbcCoordinator , this );
239
237
}
240
238
}
@@ -286,7 +284,7 @@ private JdbcSessionContextImpl createJdbcSessionContext(StatementInspector state
286
284
statementInspector ,
287
285
connectionHandlingMode ,
288
286
getJdbcServices (),
289
- fastSessionServices . getBatchBuilder () ,
287
+ factory . batchBuilder ,
290
288
// TODO: this object is deprecated and should be removed
291
289
new JdbcEventHandler (
292
290
factory .getStatistics (),
@@ -575,7 +573,7 @@ private boolean isTransactionAccessible() {
575
573
final SessionFactoryOptions sessionFactoryOptions = getSessionFactoryOptions ();
576
574
return sessionFactoryOptions .isJtaTransactionAccessEnabled () // defaults to false in JPA bootstrap
577
575
|| !sessionFactoryOptions .getJpaCompliance ().isJpaTransactionComplianceEnabled ()
578
- || !fastSessionServices . getTransactionCoordinatorBuilder () .isJta ();
576
+ || !factory . transactionCoordinatorBuilder .isJta ();
579
577
}
580
578
581
579
@ Override
@@ -698,15 +696,15 @@ public JdbcConnectionAccess getJdbcConnectionAccess() {
698
696
if ( !getSessionFactoryOptions ().isMultiTenancyEnabled () ) {
699
697
jdbcConnectionAccess = new NonContextualJdbcConnectionAccess (
700
698
getEventListenerManager (),
701
- fastSessionServices . getConnectionProvider () ,
699
+ factory . connectionProvider ,
702
700
this
703
701
);
704
702
}
705
703
else {
706
704
jdbcConnectionAccess = new ContextualJdbcConnectionAccess (
707
705
getTenantIdentifierValue (),
708
706
getEventListenerManager (),
709
- fastSessionServices . getMultiTenantConnectionProvider () ,
707
+ factory . multiTenantConnectionProvider ,
710
708
this
711
709
);
712
710
}
@@ -1449,7 +1447,7 @@ public void setJdbcBatchSize(Integer jdbcBatchSize) {
1449
1447
1450
1448
@ Override
1451
1449
public EventMonitor getEventMonitor () {
1452
- return fastSessionServices . getEventMonitor () ;
1450
+ return factory . eventMonitor ;
1453
1451
}
1454
1452
1455
1453
@ Override
@@ -1650,7 +1648,6 @@ private void readObject(ObjectInputStream ois) throws IOException, ClassNotFound
1650
1648
factory = SessionFactoryImpl .deserialize ( ois );
1651
1649
factoryOptions = factory .getSessionFactoryOptions ();
1652
1650
jdbcServices = factory .getJdbcServices ();
1653
- fastSessionServices = factory .getFastSessionServices ();
1654
1651
1655
1652
//TODO: this isn't quite right, see createSessionEventsManager()
1656
1653
final SessionEventListener [] baseline =
@@ -1663,8 +1660,7 @@ private void readObject(ObjectInputStream ois) throws IOException, ClassNotFound
1663
1660
1664
1661
cacheTransactionSync = factory .getCache ().getRegionFactory ().createTransactionContext ( this );
1665
1662
transactionCoordinator =
1666
- fastSessionServices .getTransactionCoordinatorBuilder ()
1667
- .buildTransactionCoordinator ( jdbcCoordinator , this );
1663
+ factory .transactionCoordinatorBuilder .buildTransactionCoordinator ( jdbcCoordinator , this );
1668
1664
1669
1665
entityNameResolver = new CoordinatingEntityNameResolver ( factory , interceptor );
1670
1666
}
0 commit comments