Package org.keycloak.models.sessions.infinispan.changes

Class UserSessionPersistentChangelogBasedTransaction

java.lang.Object

org.keycloak.models.sessions.infinispan.changes.PersistentSessionsChangelogBasedTransaction<String,UserSessionEntity>

org.keycloak.models.sessions.infinispan.changes.UserSessionPersistentChangelogBasedTransaction

All Implemented Interfaces:

SessionsChangelogBasedTransaction<String,UserSessionEntity>, NonBlockingTransaction

public class UserSessionPersistentChangelogBasedTransaction
extends PersistentSessionsChangelogBasedTransaction<String,UserSessionEntity>

Field Summary

Fields inherited from class org.keycloak.models.sessions.infinispan.changes.PersistentSessionsChangelogBasedTransaction

kcSession, offlineUpdates, updates

Constructor Summary

Constructors

Constructor	Description
UserSessionPersistentChangelogBasedTransaction(KeycloakSession session, ArrayBlockingQueue<PersistentUpdate> batchingQueue, CacheHolder<String,UserSessionEntity> cacheHolder, CacheHolder<String,UserSessionEntity> offlineCacheHolder)

Method Summary

Modifier and Type	Method	Description
SessionEntityWrapper<UserSessionEntity>	get(RealmModel realm, String key, UserSessionModel userSession, boolean offline)
boolean	isScheduledForRemove(String key, boolean offline)
void	registerClientSession(String userSessionId, String clientId, boolean offline)

Methods inherited from class org.keycloak.models.sessions.infinispan.changes.PersistentSessionsChangelogBasedTransaction

addTask, addTask, asyncCommit, asyncRollback, generateKey, get, getCache, getLifespanMsLoader, getMaxIdleMsLoader, getUpdates, importSession, importSessionsConcurrently, reloadEntityInCurrentTransaction, restartEntity

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UserSessionPersistentChangelogBasedTransaction

public UserSessionPersistentChangelogBasedTransaction(KeycloakSession session,
 ArrayBlockingQueue<PersistentUpdate> batchingQueue,
 CacheHolder<String,UserSessionEntity> cacheHolder,
 CacheHolder<String,UserSessionEntity> offlineCacheHolder)

Method Details

get

public SessionEntityWrapper<UserSessionEntity> get(RealmModel realm,
 String key,
 UserSessionModel userSession,
 boolean offline)

isScheduledForRemove

public boolean isScheduledForRemove(String key,
 boolean offline)

registerClientSession

public void registerClientSession(String userSessionId,
 String clientId,
 boolean offline)