Package org.keycloak.models.sessions.infinispan.remotestore

Class RemoteCacheSessionListener<K,V extends SessionEntity>

java.lang.Object

org.keycloak.models.sessions.infinispan.remotestore.RemoteCacheSessionListener<K,V>

public class RemoteCacheSessionListener<K,V extends SessionEntity>
extends Object

Author:

Marek Posolda

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.jboss.logging.Logger	logger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RemoteCacheSessionListener(Runnable onFailover)

Method Summary

Modifier and Type	Method	Description
void	cacheFailover(org.infinispan.client.hotrod.event.ClientCacheFailoverEvent event)
void	created(org.infinispan.client.hotrod.event.ClientCacheEntryCreatedEvent event)
static <K, V extends SessionEntity> RemoteCacheSessionListener	createListener(KeycloakSession session, org.infinispan.Cache<K,SessionEntityWrapper<V>> cache, org.infinispan.client.hotrod.RemoteCache<K,SessionEntityWrapper<V>> remoteCache, SessionFunction<V> lifespanMsLoader, SessionFunction<V> maxIdleTimeMsLoader, Runnable onFailover)
protected void	createRemoteEntityInCache(K key)
protected void	init(KeycloakSession session, org.infinispan.Cache<K,SessionEntityWrapper<V>> cache, org.infinispan.client.hotrod.RemoteCache<K,SessionEntityWrapper<V>> remoteCache, SessionFunction<V> lifespanMsLoader, SessionFunction<V> maxIdleTimeMsLoader)
void	removed(org.infinispan.client.hotrod.event.ClientCacheEntryRemovedEvent event)
protected void	replaceRemoteEntityInCache(K key, long eventVersion)
protected boolean	shouldUpdateLocalCache(org.infinispan.client.hotrod.event.ClientEvent.Type type, K key, boolean commandRetried)
void	updated(org.infinispan.client.hotrod.event.ClientCacheEntryModifiedEvent event)

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.jboss.logging.Logger logger

Constructor Details

RemoteCacheSessionListener

protected RemoteCacheSessionListener(Runnable onFailover)

Method Details

init

protected void init(KeycloakSession session,
 org.infinispan.Cache<K,SessionEntityWrapper<V>> cache,
 org.infinispan.client.hotrod.RemoteCache<K,SessionEntityWrapper<V>> remoteCache,
 SessionFunction<V> lifespanMsLoader,
 SessionFunction<V> maxIdleTimeMsLoader)

created

public void created(org.infinispan.client.hotrod.event.ClientCacheEntryCreatedEvent event)

cacheFailover

public void cacheFailover(org.infinispan.client.hotrod.event.ClientCacheFailoverEvent event)

updated

public void updated(org.infinispan.client.hotrod.event.ClientCacheEntryModifiedEvent event)

createRemoteEntityInCache

protected void createRemoteEntityInCache(K key)

replaceRemoteEntityInCache

protected void replaceRemoteEntityInCache(K key,
 long eventVersion)

removed

public void removed(org.infinispan.client.hotrod.event.ClientCacheEntryRemovedEvent event)

shouldUpdateLocalCache

protected boolean shouldUpdateLocalCache(org.infinispan.client.hotrod.event.ClientEvent.Type type,
 K key,
 boolean commandRetried)

createListener

public static <K,
V extends SessionEntity>
RemoteCacheSessionListener createListener(KeycloakSession session,
 org.infinispan.Cache<K,SessionEntityWrapper<V>> cache,
 org.infinispan.client.hotrod.RemoteCache<K,SessionEntityWrapper<V>> remoteCache,
 SessionFunction<V> lifespanMsLoader,
 SessionFunction<V> maxIdleTimeMsLoader,
 Runnable onFailover)