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

Class PersistentSessionsChangelogBasedTransaction<K,V extends SessionEntity>

java.lang.Object

org.keycloak.models.AbstractKeycloakTransaction

org.keycloak.models.sessions.infinispan.changes.PersistentSessionsChangelogBasedTransaction<K,V>

All Implemented Interfaces:

KeycloakTransaction, SessionsChangelogBasedTransaction<K,V>

Direct Known Subclasses:

ClientSessionPersistentChangelogBasedTransaction, UserSessionPersistentChangelogBasedTransaction

public abstract class PersistentSessionsChangelogBasedTransaction<K,V extends SessionEntity>
extends AbstractKeycloakTransaction
implements SessionsChangelogBasedTransaction<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class org.keycloak.models.AbstractKeycloakTransaction

AbstractKeycloakTransaction.TransactionState

Field Summary

Fields

Modifier and Type	Field	Description
protected final KeycloakSession	kcSession
protected final Map<K,SessionUpdatesList<V>>	offlineUpdates
protected final Map<K,SessionUpdatesList<V>>	updates

Fields inherited from class org.keycloak.models.AbstractKeycloakTransaction

state

Constructor Summary

Constructors

Constructor

Description

PersistentSessionsChangelogBasedTransaction(KeycloakSession session, String cacheName, org.infinispan.Cache<K,SessionEntityWrapper<V>> cache, org.infinispan.Cache<K,SessionEntityWrapper<V>> offlineCache, RemoteCacheInvoker remoteCacheInvoker, SessionFunction<V> lifespanMsLoader, SessionFunction<V> maxIdleTimeMsLoader, SessionFunction<V> offlineLifespanMsLoader, SessionFunction<V> offlineMaxIdleTimeMsLoader, ArrayBlockingQueue<PersistentUpdate> batchingQueue, SerializeExecutionsByKey<K> serializerOnline, SerializeExecutionsByKey<K> serializerOffline)

Method Summary

Modifier and Type	Method	Description
void	addTask(K key, SessionUpdateTask<V> originalTask)
void	addTask(K key, SessionUpdateTask<V> task, V entity, UserSessionModel.SessionPersistenceState persistenceState)
protected void	commitImpl()
SessionEntityWrapper<V>	get(K key, boolean offline)
protected org.infinispan.Cache<K,SessionEntityWrapper<V>>	getCache(boolean offline)
protected SessionFunction<V>	getLifespanMsLoader(boolean offline)
protected SessionFunction<V>	getMaxIdleMsLoader(boolean offline)
protected Map<K,SessionUpdatesList<V>>	getUpdates(boolean offline)
void	reloadEntityInCurrentTransaction(RealmModel realm, K key, SessionEntityWrapper<V> entity)
protected void	rollbackImpl()

Methods inherited from class org.keycloak.models.AbstractKeycloakTransaction

begin, beginImpl, commit, getRollbackOnly, getState, isActive, rollback, setRollbackOnly

Methods inherited from class java.lang.Object

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

Field Details

kcSession

protected final KeycloakSession kcSession

updates

protected final Map<K,SessionUpdatesList<V extends SessionEntity>> updates

offlineUpdates

protected final Map<K,SessionUpdatesList<V extends SessionEntity>> offlineUpdates

Constructor Details

PersistentSessionsChangelogBasedTransaction

public PersistentSessionsChangelogBasedTransaction(KeycloakSession session,
 String cacheName,
 org.infinispan.Cache<K,SessionEntityWrapper<V>> cache,
 org.infinispan.Cache<K,SessionEntityWrapper<V>> offlineCache,
 RemoteCacheInvoker remoteCacheInvoker,
 SessionFunction<V> lifespanMsLoader,
 SessionFunction<V> maxIdleTimeMsLoader,
 SessionFunction<V> offlineLifespanMsLoader,
 SessionFunction<V> offlineMaxIdleTimeMsLoader,
 ArrayBlockingQueue<PersistentUpdate> batchingQueue,
 SerializeExecutionsByKey<K> serializerOnline,
 SerializeExecutionsByKey<K> serializerOffline)

Method Details

getCache

protected org.infinispan.Cache<K,SessionEntityWrapper<V>> getCache(boolean offline)

getLifespanMsLoader

protected SessionFunction<V> getLifespanMsLoader(boolean offline)

getMaxIdleMsLoader

protected SessionFunction<V> getMaxIdleMsLoader(boolean offline)

getUpdates

protected Map<K,SessionUpdatesList<V>> getUpdates(boolean offline)

get

public SessionEntityWrapper<V> get(K key,
 boolean offline)

commitImpl

protected void commitImpl()

Specified by:

commitImpl in class AbstractKeycloakTransaction

addTask

public void addTask(K key,
 SessionUpdateTask<V> originalTask)

Specified by:

addTask in interface SessionsChangelogBasedTransaction<K,V extends SessionEntity>

addTask

public void addTask(K key,
 SessionUpdateTask<V> task,
 V entity,
 UserSessionModel.SessionPersistenceState persistenceState)

reloadEntityInCurrentTransaction

public void reloadEntityInCurrentTransaction(RealmModel realm,
 K key,
 SessionEntityWrapper<V> entity)

rollbackImpl

protected void rollbackImpl()

Specified by:

rollbackImpl in class AbstractKeycloakTransaction