add SessionFactory.close()

to clean up Vert.x and its Pool

Author: gavinking

example/src/main/java/org/hibernate/example/reactive/Main.java

@@ -79,7 +79,7 @@ public static void main(String[] args) {
 		)
 				.toCompletableFuture().join();
 
-		System.exit(0);
+		sessionFactory.close();
 	}
 
 }

example/src/main/java/org/hibernate/example/reactive/MutinyMain.java

@@ -78,7 +78,7 @@ public static void main(String[] args) {
 		)
 				.await().indefinitely();
 
-		System.exit(0);
+		sessionFactory.close();
 	}
 
 }

hibernate-reactive-core/src/main/java/org/hibernate/reactive/mutiny/Mutiny.java

@@ -595,5 +595,10 @@ interface SessionFactory {
 		 */
 		<T> Uni<T> withReactiveSession(Function<Session, Uni<T>> work);
 
+		/**
+		 * Destroy the session factory and clean up its connection
+		 * pool.
+		 */
+		void close();
 	}
 }

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

@@ -39,4 +39,8 @@ public <T> Uni<T> withReactiveSession(Function<Mutiny.Session, Uni<T>> work) {
 		);
 	}
 
+	@Override
+	public void close() {
+		delegate.close();
+	}
 }

hibernate-reactive-core/src/main/java/org/hibernate/reactive/stage/Stage.java

@@ -595,5 +595,10 @@ interface SessionFactory {
 		 */
 		<T> CompletionStage<T> withReactiveSession(Function<Session, CompletionStage<T>> work);
 
+		/**
+		 * Destroy the session factory and clean up its connection
+		 * pool.
+		 */
+		void close();
 	}
 }

hibernate-reactive-core/src/main/java/org/hibernate/reactive/stage/impl/StageSessionFactoryImpl.java

@@ -40,4 +40,8 @@ public <T> CompletionStage<T> withReactiveSession(Function<Stage.Session, Comple
 		);
 	}
 
+	@Override
+	public void close() {
+		delegate.close();
+	}
 }

hibernate-reactive-core/src/main/java/org/hibernate/reactive/vertx/impl/ProvidedVertxInstance.java

@@ -8,7 +8,7 @@
 /**
  * An implementation of {@link VertxInstance} which allows the client
  * to provide an instance of {@link Vertx} whose lifecyle is managed
- * extrenally to Hibernate Reactive. The {@code ProvidedVertxInstance}
+ * externally to Hibernate Reactive. The {@code ProvidedVertxInstance}
  * must be registered with explicitly Hibernate by calling
  * {@link org.hibernate.boot.registry.StandardServiceRegistryBuilder#addService}.
  * Hibernate will destroy the {@code Vertx} instance on shutdown.