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

Class InfinispanChangelogBasedTransaction<K,V extends SessionEntity>

java.lang.Object

org.keycloak.models.AbstractKeycloakTransaction

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

All Implemented Interfaces:

KeycloakTransaction, SessionsChangelogBasedTransaction<K,V>

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

Author:

Marek Posolda

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 org.infinispan.Cache<K,SessionEntityWrapper<V>>	cache
protected final KeycloakSession	kcSession
protected final SessionFunction<V>	lifespanMsLoader
static final org.jboss.logging.Logger	logger
protected final SessionFunction<V>	maxIdleTimeMsLoader
protected final Map<K,SessionUpdatesList<V>>	updates

Fields inherited from class org.keycloak.models.AbstractKeycloakTransaction

state

Constructor Summary

Constructors

Constructor	Description
InfinispanChangelogBasedTransaction(KeycloakSession kcSession, org.infinispan.Cache<K,SessionEntityWrapper<V>> cache, RemoteCacheInvoker remoteCacheInvoker, SessionFunction<V> lifespanMsLoader, SessionFunction<V> maxIdleTimeMsLoader, SerializeExecutionsByKey<K> serializer)

Method Summary

Modifier and Type	Method	Description
void	addTask(K key, SessionUpdateTask<V> task)
void	addTask(K key, SessionUpdateTask<V> task, V entity, UserSessionModel.SessionPersistenceState persistenceState)
protected void	commitImpl()
SessionEntityWrapper<V>	get(K key)
void	reloadEntityInCurrentTransaction(RealmModel realm, K key, SessionEntityWrapper<V> entity)
protected void	rollbackImpl()

Methods inherited from class org.keycloak.models.AbstractKeycloakTransaction

begin, 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

logger

public static final org.jboss.logging.Logger logger

kcSession

protected final KeycloakSession kcSession

cache

protected final org.infinispan.Cache<K,SessionEntityWrapper<V extends SessionEntity>> cache

updates

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

lifespanMsLoader

protected final SessionFunction<V extends SessionEntity> lifespanMsLoader

maxIdleTimeMsLoader

protected final SessionFunction<V extends SessionEntity> maxIdleTimeMsLoader

Constructor Details

InfinispanChangelogBasedTransaction

public InfinispanChangelogBasedTransaction(KeycloakSession kcSession,
 org.infinispan.Cache<K,SessionEntityWrapper<V>> cache,
 RemoteCacheInvoker remoteCacheInvoker,
 SessionFunction<V> lifespanMsLoader,
 SessionFunction<V> maxIdleTimeMsLoader,
 SerializeExecutionsByKey<K> serializer)

Method Details

addTask

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

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)

get

public SessionEntityWrapper<V> get(K key)

commitImpl

protected void commitImpl()

Specified by:

commitImpl in class AbstractKeycloakTransaction

rollbackImpl

protected void rollbackImpl()

Specified by:

rollbackImpl in class AbstractKeycloakTransaction