remove cruft, including ProxyConnection

Author: gavinking

hibernate-reactive-core/src/main/java/org/hibernate/reactive/common/spi/MutinyImplementor.java

@@ -12,7 +12,6 @@
 import org.hibernate.internal.SessionCreationOptions;
 import org.hibernate.internal.SessionFactoryImpl;
 import org.hibernate.reactive.common.spi.Implementor;
-import org.hibernate.reactive.common.spi.MutinyImplementor;
 import org.hibernate.reactive.context.Context;
 import org.hibernate.reactive.context.impl.BaseKey;
 import org.hibernate.reactive.context.impl.MultitenantKey;
@@ -40,7 +39,7 @@
  * <p>
  * Obtained by calling {@link org.hibernate.SessionFactory#unwrap(Class)}.
  */
-public class MutinySessionFactoryImpl implements Mutiny.SessionFactory, Implementor, MutinyImplementor {
+public class MutinySessionFactoryImpl implements Mutiny.SessionFactory, Implementor {
 
 	private static final Log LOG = LoggerFactory.make( Log.class, MethodHandles.lookup() );
 
@@ -85,24 +84,6 @@ public Context getContext() {
 		return context;
 	}
 
-	@Override
-	public Mutiny.Session newSession() {
-		SessionCreationOptions options = options();
-		return new MutinySessionImpl(
-				new ReactiveSessionImpl( delegate, options, proxyConnection( options.getTenantIdentifier() ) ),
-				this
-		);
-	}
-
-	@Override
-	public Mutiny.Session newSession(String tenantId) {
-		Objects.requireNonNull( tenantId, "parameter 'tenantId' is required" );
-		return new MutinySessionImpl(
-				new ReactiveSessionImpl( delegate, options( tenantId ), proxyConnection( tenantId ) ),
-				this
-		);
-	}
-
 	@Override
 	public Uni<Mutiny.Session> openSession() {
 		SessionCreationOptions options = options();
@@ -128,23 +109,6 @@ private <S> Uni<S> create(ReactiveConnection connection, Supplier<S> supplier) {
 				.onFailure().call( () -> Uni.createFrom().completionStage( connection.close() ) );
 	}
 
-	@Override
-	public Mutiny.StatelessSession newStatelessSession() {
-		SessionCreationOptions options = options();
-		return new MutinyStatelessSessionImpl(
-				new ReactiveStatelessSessionImpl( delegate, options, proxyConnection( options.getTenantIdentifier() ) ),
-				this
-		);
-	}
-
-	@Override
-	public Mutiny.StatelessSession newStatelessSession(String tenantId) {
-		return new MutinyStatelessSessionImpl(
-				new ReactiveStatelessSessionImpl( delegate, options( tenantId ), proxyConnection( tenantId ) ),
-				this
-		);
-	}
-
 	@Override
 	public Uni<Mutiny.StatelessSession> openStatelessSession() {
 		SessionCreationOptions options = options();
@@ -167,7 +131,7 @@ private SessionCreationOptions options() {
 	}
 
 	private SessionCreationOptions options(String tenantIdentifier) {
-		return (SessionCreationOptions) new SessionFactoryImpl.SessionBuilderImpl( delegate )
+		return new SessionFactoryImpl.SessionBuilderImpl( delegate )
 				.tenantIdentifier( tenantIdentifier );
 	}
 
@@ -178,13 +142,6 @@ private CompletionStage<ReactiveConnection> connection(String tenantId) {
 				: connectionPool.getConnection( tenantId );
 	}
 
-	private ReactiveConnection proxyConnection(String tenantId) {
-		assertUseOnEventLoop();
-		return tenantId==null
-				? connectionPool.getProxyConnection()
-				: connectionPool.getProxyConnection( tenantId );
-	}
-
 	@Override
 	public <T> Uni<T> withSession(Function<Mutiny.Session, Uni<T>> work) {
 		Objects.requireNonNull( work, "parameter 'work' is required" );

hibernate-reactive-core/src/main/java/org/hibernate/reactive/mutiny/impl/MutinySessionFactoryImpl.java

@@ -25,8 +25,7 @@
  * with a single {@code ReactiveConnection}. Instead, the second
  * operation must be chained on completion of the first operation.
  * This restriction might be relaxed in future, and is due to the
- * implementation of the {@code ProxyConnection} returned by
- * {@link org.hibernate.reactive.pool.impl.DefaultSqlClientPool#getProxyConnection()}.
+ * implementation of the {@code ProxyConnection}.
  *
  * @see ReactiveConnectionPool
  */

hibernate-reactive-core/src/main/java/org/hibernate/reactive/pool/ReactiveConnection.java

@@ -63,21 +63,6 @@ public interface ReactiveConnectionPool extends Service {
 	 */
 	CompletionStage<ReactiveConnection> getConnection(String tenantId, SqlExceptionHelper sqlExceptionHelper);
 
-	/**
-	 * Obtain a lazily-initializing reactive connection. The
-	 * actual connection might be made when the returned
-	 * instance if {@link ReactiveConnection} is first used.
-	 */
-	ReactiveConnection getProxyConnection();
-
-	/**
-	 * Obtain a lazily-initializing reactive connection for the
-	 * given tenant id. The actual connection might be made when
-	 * the returned instance if {@link ReactiveConnection} is
-	 * first used.
-	 */
-	ReactiveConnection getProxyConnection(String tenantId);
-
 	/**
 	 * The shutdown of the pool is actually asynchronous but the
 	 * core service registry won't return the {@link CompletionStage}.