very minor changes

Author: gavinking

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

@@ -562,7 +562,7 @@ private static Object createProxyIfNecessary(
 
 	private static Object createProxy(LoadEvent event, EntityPersister persister, EntityKey keyToLoad) {
 		// return new uninitialized proxy
-		Object proxy = persister.createProxy( event.getEntityId(), event.getSession() );
+		final Object proxy = persister.createProxy( event.getEntityId(), event.getSession() );
 		PersistenceContext persistenceContext = event.getSession().getPersistenceContextInternal();
 		persistenceContext.getBatchFetchQueue().addBatchLoadableEntityKey( keyToLoad );
 		persistenceContext.addProxy( keyToLoad, proxy );
@@ -588,11 +588,11 @@ private CompletionStage<Object> lockAndLoad(
 			LoadType options,
 			SessionImplementor source) {
 
-		final boolean canWriteToCache = persister.canWriteToCache();
 		final SoftLock lock;
 		final Object cacheKey;
+		final boolean canWriteToCache = persister.canWriteToCache();
 		if ( canWriteToCache ) {
-			EntityDataAccess cache = persister.getCacheAccessStrategy();
+			final EntityDataAccess cache = persister.getCacheAccessStrategy();
 			cacheKey = cache.generateCacheKey(
 					event.getEntityId(),
 					persister,

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

@@ -15,7 +15,6 @@
 import org.hibernate.engine.spi.SessionImplementor;
 import org.hibernate.engine.spi.Status;
 import org.hibernate.event.internal.EntityState;
-import org.hibernate.event.internal.EventUtil;
 import org.hibernate.event.spi.EventSource;
 import org.hibernate.event.spi.PersistContext;
 import org.hibernate.event.spi.PersistEvent;
@@ -32,6 +31,7 @@
 import org.hibernate.reactive.logging.impl.LoggerFactory;
 
 import static org.hibernate.event.internal.EntityState.getEntityState;
+import static org.hibernate.event.internal.EventUtil.getLoggableName;
 import static org.hibernate.pretty.MessageHelper.infoString;
 import static org.hibernate.reactive.util.impl.CompletionStages.failedFuture;
 import static org.hibernate.reactive.util.impl.CompletionStages.voidFuture;
@@ -100,13 +100,13 @@ private CompletionStage<Void> persist(PersistEvent event, PersistContext createC
 		switch ( entityState( event, entity, entityName, entityEntry ) ) {
 			case DETACHED:
 				return failedFuture( new PersistentObjectException(
-						"detached entity passed to persist: " +
-								EventUtil.getLoggableName(event.getEntityName(), entity)
+						"detached entity passed to persist: "
+								+ getLoggableName( event.getEntityName(), entity )
 				) );
 			case PERSISTENT:
-				return entityIsPersistent(event, createCache);
+				return entityIsPersistent( event, createCache );
 			case TRANSIENT:
-				return entityIsTransient(event, createCache);
+				return entityIsTransient( event, createCache );
 			case DELETED:
 				entityEntry.setStatus( Status.MANAGED );
 				entityEntry.setDeletedState( null );
@@ -116,7 +116,7 @@ private CompletionStage<Void> persist(PersistEvent event, PersistContext createC
 				return failedFuture( new ObjectDeletedException(
 						"deleted entity passed to persist",
 						null,
-						EventUtil.getLoggableName( event.getEntityName(), entity )
+						getLoggableName( event.getEntityName(), entity )
 				) );
 		}
 	}
@@ -135,7 +135,7 @@ private static EntityState entityState(PersistEvent event, Object entity, String
 
 			// NOTE: entityEntry must be null to get here, so we cannot use any of its values
 			final EntityPersister persister = source.getFactory().getMappingMetamodel()
-					.getEntityDescriptor(entityName);
+					.getEntityDescriptor( entityName );
 			if ( persister.getGenerator() instanceof ForeignGenerator ) {
 				if ( LOG.isDebugEnabled() && persister.getIdentifier( entity, source ) != null ) {
 					LOG.debug( "Resetting entity id attribute to null for foreign generator" );

hibernate-reactive-core/src/main/java/org/hibernate/reactive/id/impl/TableReactiveIdentifierGenerator.java

@@ -77,7 +77,7 @@ protected CompletionStage<Long> nextHiValue(ReactiveConnectionSupplier session)
 		// and update it by the specified increment, but we
 		// need to do it atomically, and without depending on
 		// transaction rollback.
-		ReactiveConnection connection = session.getReactiveConnection();
+		final ReactiveConnection connection = session.getReactiveConnection();
 		// 1) select the current hi value
 		return connection
 				.selectIdentifier( selectQuery, selectParameters(), Long.class )