[#2768] Add exception for the execution on the wrong context

For now we use it only when the connection is used

Author: DavideD

hibernate-reactive-core/src/main/java/org/hibernate/reactive/common/InternalStateAssertions.java

@@ -7,11 +7,13 @@
 
 import java.lang.invoke.MethodHandles;
 import java.util.Locale;
+import java.util.Objects;
 
 import org.hibernate.reactive.logging.impl.Log;
 import org.hibernate.reactive.logging.impl.LoggerFactory;
 
 import io.vertx.core.Context;
+import io.vertx.core.internal.ContextInternal;
 
 /**
  * Commonly used assertions to verify that the operations
@@ -52,4 +54,13 @@ public static void assertCurrentThreadMatches(Thread expectedThread) {
 		}
 	}
 
+	public static void assertCurrentContextMatches(Object object, ContextInternal expectedContext) {
+		if ( ENFORCE ) {
+			final ContextInternal currentContext = ContextInternal.current();
+			Objects.requireNonNull( currentContext, "Current context cannot be null" );
+			if ( !currentContext.equals( expectedContext ) ) {
+				throw LOG.unexpectedContextDetected( object, expectedContext, currentContext );
+			}
+		}
+	}
 }

hibernate-reactive-core/src/main/java/org/hibernate/reactive/logging/impl/Log.java

@@ -6,12 +6,9 @@
 package org.hibernate.reactive.logging.impl;
 
 
-
 import java.sql.SQLException;
 import java.sql.SQLWarning;
 
-import jakarta.persistence.PersistenceException;
-
 import org.hibernate.HibernateException;
 import org.hibernate.JDBCException;
 import org.hibernate.LazyInitializationException;
@@ -26,6 +23,9 @@
 import org.jboss.logging.annotations.Message;
 import org.jboss.logging.annotations.MessageLogger;
 
+import io.vertx.core.internal.ContextInternal;
+import jakarta.persistence.PersistenceException;
+
 import static org.jboss.logging.Logger.Level.DEBUG;
 import static org.jboss.logging.Logger.Level.ERROR;
 import static org.jboss.logging.Logger.Level.INFO;
@@ -277,6 +277,9 @@ public interface Log extends BasicLogger {
 	@Message(id = 87, value = "Retrieved key was null, but to-one is not nullable : %s")
 	IllegalStateException notNullableToOneAssociationMissingKey(String toOneNavigablePath);
 
+	@Message(id = 88, value = "Expected to use the object %1$s on context %2$s but was %3$s")
+	HibernateException unexpectedContextDetected(Object obj, ContextInternal expectedContext, ContextInternal currentContext);
+
 	// Same method that exists in CoreMessageLogger
 	@LogMessage(level = WARN)
 	@Message(id = 104, value = "firstResult/maxResults specified with collection fetch; applying in memory!" )