mirror/keycloak
1
0
Fork 0
mirror of https://github.com/keycloak/keycloak.git synced 2025-12-21 06:20:05 -06:00
Code Issues Packages Projects Releases Wiki Activity

Prevent using JTA transaction when initializing JDBC_PING

Browse Source 
Closes #43335

Signed-off-by: Alexander Schwartz <alexander.schwartz@ibm.com>
This commit is contained in:
Alexander Schwartz
2025-10-14 11:15:37 +02:00
committed by GitHub
parent cce230818e
commit a97613bf7b
1 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
quarkus/runtime/src/main/java/org/keycloak/quarkus/runtime/storage/infinispan/CacheManagerFactory.java
View File

@@ -71,6 +71,7 @@ import org.keycloak.models.sessions.infinispan.query.ClientSessionQueries;
import org.keycloak.models.sessions.infinispan.query.UserSessionQueries;
import org.keycloak.models.sessions.infinispan.remote.RemoteInfinispanAuthenticationSessionProviderFactory;
import org.keycloak.models.sessions.infinispan.remote.RemoteUserLoginFailureProviderFactory;
import org.keycloak.models.utils.KeycloakModelUtils;
import org.keycloak.quarkus.runtime.configuration.Configuration;
import org.keycloak.quarkus.runtime.storage.infinispan.jgroups.JGroupsConfigurator;
@@ -339,7 +340,24 @@ public class CacheManagerFactory {
checkForRemoteStores(builder);
configureMetrics(builder);
return new DefaultCacheManager(builder, isStartEagerly());
return getDefaultCacheManager(session, builder);
}
private static DefaultCacheManager getDefaultCacheManager(KeycloakSession session, ConfigurationBuilderHolder holder) {
if (session == null) {
// If there is no session, this is not using JDBC_PING, and therefore we do not need and also can not suspend the JTA transaction context
return getDefaultCacheManager(holder);
}
// This disables the JTA transaction context to avoid binding all JDBC_PING2 interactions to the current transaction
DefaultCacheManager[] _cm = new DefaultCacheManager[1];
KeycloakModelUtils.suspendJtaTransaction(session.getKeycloakSessionFactory(), () ->
_cm[0] = getDefaultCacheManager(holder)
);
return _cm[0];
}
private static DefaultCacheManager getDefaultCacheManager(ConfigurationBuilderHolder holder) {
return new DefaultCacheManager(holder, isStartEagerly());
}
/**