Fix serializer naming

Signed-off-by: Michal Hajas <mhajas@redhat.com>
keycloak · May 9, 2024 · b3149e3 · b3149e3
1 parent 00d059a
commit b3149e3
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/.../models/sessions/infinispan/changes/ClientSessionPersistentChangelogBasedTransaction.java b/.../models/sessions/infinispan/changes/ClientSessionPersistentChangelogBasedTransaction.java
@@ -53,9 +53,9 @@ public ClientSessionPersistentChangelogBasedTransaction(KeycloakSession session,
                                                             SessionFunction<AuthenticatedClientSessionEntity> offlineMaxIdleTimeMsLoader,
                                                             UserSessionPersistentChangelogBasedTransaction userSessionTx,
                                                             ArrayBlockingQueue<PersistentUpdate> batchingQueue,
-                                                            SerializeExecutionsByKey<UUID> sessions,
-                                                            SerializeExecutionsByKey<UUID> offlineSessions) {
-        super(session, cache, offlineCache, remoteCacheInvoker, lifespanMsLoader, maxIdleTimeMsLoader, offlineLifespanMsLoader, offlineMaxIdleTimeMsLoader, batchingQueue, sessions, offlineSessions);
+                                                            SerializeExecutionsByKey<UUID> serializerOnline,
+                                                            SerializeExecutionsByKey<UUID> serializerOffline) {
+        super(session, cache, offlineCache, remoteCacheInvoker, lifespanMsLoader, maxIdleTimeMsLoader, offlineLifespanMsLoader, offlineMaxIdleTimeMsLoader, batchingQueue, serializerOnline, serializerOffline);
         this.userSessionTx = userSessionTx;
     }
 

diff --git a/...cloak/models/sessions/infinispan/changes/PersistentSessionsChangelogBasedTransaction.java b/...cloak/models/sessions/infinispan/changes/PersistentSessionsChangelogBasedTransaction.java
@@ -62,8 +62,8 @@ public PersistentSessionsChangelogBasedTransaction(KeycloakSession session,
                                                        SessionFunction<V> offlineLifespanMsLoader,
                                                        SessionFunction<V> offlineMaxIdleTimeMsLoader,
                                                        ArrayBlockingQueue<PersistentUpdate> batchingQueue,
-                                                       SerializeExecutionsByKey<K> sessions,
-                                                       SerializeExecutionsByKey<K> offlineSessions) {
+                                                       SerializeExecutionsByKey<K> serializerOnline,
+                                                       SerializeExecutionsByKey<K> serializerOffline) {
         kcSession = session;
 
         if (!Profile.isFeatureEnabled(Profile.Feature.PERSISTENT_USER_SESSIONS)) {
@@ -81,13 +81,13 @@ public PersistentSessionsChangelogBasedTransaction(KeycloakSession session,
 
         changesPerformers = List.of(
                 new JpaChangesPerformer<>(cache.getName(), batchingQueue),
-                new EmbeddedCachesChangesPerformer<>(cache, sessions) {
+                new EmbeddedCachesChangesPerformer<>(cache, serializerOnline) {
                     @Override
                     public boolean shouldConsumeChange(V entity) {
                         return !entity.isOffline();
                     }
                 },
-                new EmbeddedCachesChangesPerformer<>(offlineCache, offlineSessions){
+                new EmbeddedCachesChangesPerformer<>(offlineCache, serializerOffline){
                     @Override
                     public boolean shouldConsumeChange(V entity) {
                         return entity.isOffline();

diff --git a/...ak/models/sessions/infinispan/changes/UserSessionPersistentChangelogBasedTransaction.java b/...ak/models/sessions/infinispan/changes/UserSessionPersistentChangelogBasedTransaction.java
@@ -45,9 +45,9 @@ public UserSessionPersistentChangelogBasedTransaction(KeycloakSession session,
                                                           SessionFunction<UserSessionEntity> offlineLifespanMsLoader,
                                                           SessionFunction<UserSessionEntity> offlineMaxIdleTimeMsLoader,
                                                           ArrayBlockingQueue<PersistentUpdate> batchingQueue,
-                                                          SerializeExecutionsByKey<String> sessions,
-                                                          SerializeExecutionsByKey<String> offlineSessions) {
-        super(session, cache, offlineCache, remoteCacheInvoker, lifespanMsLoader, maxIdleTimeMsLoader, offlineLifespanMsLoader, offlineMaxIdleTimeMsLoader, batchingQueue, sessions, offlineSessions);
+                                                          SerializeExecutionsByKey<String> serializerOnline,
+                                                          SerializeExecutionsByKey<String> serializerOffline) {
+        super(session, cache, offlineCache, remoteCacheInvoker, lifespanMsLoader, maxIdleTimeMsLoader, offlineLifespanMsLoader, offlineMaxIdleTimeMsLoader, batchingQueue, serializerOnline, serializerOffline);
     }
 
     public SessionEntityWrapper<UserSessionEntity> get(RealmModel realm, String key, boolean offline) {