Avoid lookup of Event Listener Group(s)

Author: Sanne

hibernate-reactive-core/src/main/java/org/hibernate/reactive/event/impl/AbstractReactiveFlushingEventListener.java

@@ -19,9 +19,7 @@
 import org.hibernate.engine.spi.PersistenceContext;
 import org.hibernate.engine.spi.SessionImplementor;
 import org.hibernate.engine.spi.Status;
-import org.hibernate.event.service.spi.EventListenerRegistry;
 import org.hibernate.event.spi.EventSource;
-import org.hibernate.event.spi.EventType;
 import org.hibernate.event.spi.FlushEntityEvent;
 import org.hibernate.event.spi.FlushEntityEventListener;
 import org.hibernate.event.spi.FlushEvent;
@@ -169,9 +167,9 @@ private int flushEntities(final FlushEvent event, final PersistenceContext persi
 
 		final EventSource source = event.getSession();
 		final Iterable<FlushEntityEventListener> flushListeners =
-				source.getFactory().getServiceRegistry()
-						.getService( EventListenerRegistry.class )
-						.getEventListenerGroup( EventType.FLUSH_ENTITY )
+				source.getFactory()
+						.getFastSessionServices()
+						.eventListenerGroup_FLUSH_ENTITY
 						.listeners();
 
 		// Among other things, updateReachables() will recursively load all

hibernate-reactive-core/src/main/java/org/hibernate/reactive/loader/ReactiveLoaderBasedResultSetProcessor.java

@@ -8,9 +8,18 @@
 import org.hibernate.HibernateException;
 import org.hibernate.dialect.pagination.LimitHelper;
 import org.hibernate.engine.internal.TwoPhaseLoad;
-import org.hibernate.engine.spi.*;
+import org.hibernate.engine.spi.EntityEntry;
+import org.hibernate.engine.spi.EntityKey;
+import org.hibernate.engine.spi.PersistenceContext;
+import org.hibernate.engine.spi.QueryParameters;
+import org.hibernate.engine.spi.RowSelection;
+import org.hibernate.engine.spi.SharedSessionContractImplementor;
 import org.hibernate.event.service.spi.EventListenerRegistry;
-import org.hibernate.event.spi.*;
+import org.hibernate.event.spi.EventSource;
+import org.hibernate.event.spi.EventType;
+import org.hibernate.event.spi.PostLoadEvent;
+import org.hibernate.event.spi.PreLoadEvent;
+import org.hibernate.event.spi.PreLoadEventListener;
 import org.hibernate.internal.CoreLogging;
 import org.hibernate.internal.CoreMessageLogger;
 import org.hibernate.loader.plan.exec.query.spi.NamedParameterContext;

hibernate-reactive-core/src/main/java/org/hibernate/reactive/loader/entity/impl/ReactivePlanEntityLoader.java

@@ -8,9 +8,14 @@
 import org.hibernate.LockMode;
 import org.hibernate.LockOptions;
 import org.hibernate.MappingException;
-import org.hibernate.engine.spi.*;
-import org.hibernate.event.service.spi.EventListenerRegistry;
-import org.hibernate.event.spi.*;
+import org.hibernate.engine.spi.LoadQueryInfluencers;
+import org.hibernate.engine.spi.QueryParameters;
+import org.hibernate.engine.spi.SessionFactoryImplementor;
+import org.hibernate.engine.spi.SharedSessionContractImplementor;
+import org.hibernate.event.spi.EventSource;
+import org.hibernate.event.spi.PostLoadEvent;
+import org.hibernate.event.spi.PreLoadEvent;
+import org.hibernate.event.spi.PreLoadEventListener;
 import org.hibernate.loader.entity.plan.AbstractLoadPlanBasedEntityLoader;
 import org.hibernate.loader.plan.exec.internal.EntityLoadQueryDetails;
 import org.hibernate.loader.plan.exec.process.internal.AbstractRowReader;
@@ -431,12 +436,11 @@ public CompletionStage<Void> reactivePerformTwoPhaseLoad(
 			}
 
 			final SharedSessionContractImplementor session = context.getSession();
-			@SuppressWarnings("deprecation")
+
 			final Iterable<PreLoadEventListener> listeners = session
 					.getFactory()
-					.getServiceRegistry()
-					.getService( EventListenerRegistry.class )
-					.getEventListenerGroup( EventType.PRE_LOAD )
+					.getFastSessionServices()
+					.eventListenerGroup_PRE_LOAD
 					.listeners();
 
 			return CompletionStages.loop(

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

@@ -129,6 +129,7 @@ public class ReactiveSessionImpl extends SessionImpl implements ReactiveSession,
 
 	//Lazily initialized
 	private transient ExceptionConverter exceptionConverter;
+	private transient EventListenerRegistry eventListenerRegistry;
 
 	public ReactiveSessionImpl(SessionFactoryImpl delegate, SessionCreationOptions options,
 							   ReactiveConnection connection) {
@@ -1095,12 +1096,21 @@ private <E,L,RL,P> CompletionStage<Void> fire(E event, P extra, EventType<L> eve
 
 	@SuppressWarnings("deprecation")
 	private <T> Iterable<T> eventListeners(EventType<T> type) {
-		return getFactory().unwrap( SessionFactoryImplementor.class )
-				.getServiceRegistry().getService( EventListenerRegistry.class )
+		return getEventListenerRegistry()
 				.getEventListenerGroup( type )
 				.listeners();
 	}
 
+	private EventListenerRegistry getEventListenerRegistry() {
+		if ( this.eventListenerRegistry == null ) {
+			this.eventListenerRegistry = getFactory()
+					.unwrap( SessionFactoryImplementor.class )
+					.getServiceRegistry()
+					.getService( EventListenerRegistry.class );
+		}
+		return this.eventListenerRegistry;
+	}
+
 	private CompletionStage<Void> fireLoad(LoadEvent event, LoadEventListener.LoadType loadType) {
 		checkOpenOrWaitingForAutoClose();