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

Class JpaChangesPerformer<K,V extends SessionEntity>

java.lang.Object

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

All Implemented Interfaces:

SessionChangesPerformer<K,V>

public class JpaChangesPerformer<K,V extends SessionEntity>
extends Object
implements SessionChangesPerformer<K,V>

Constructor Summary

Constructors

Constructor	Description
JpaChangesPerformer(String cacheName, ArrayBlockingQueue<PersistentUpdate> batchingQueue)

Method Summary

Modifier and Type	Method	Description
void	applyChanges()
void	applyChangesSynchronously(KeycloakSession session)
void	registerChange(Map.Entry<K,SessionUpdatesList<V>> entry, MergedUpdate<V> merged)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.keycloak.models.sessions.infinispan.changes.SessionChangesPerformer

shouldConsumeChange

Constructor Details

JpaChangesPerformer

public JpaChangesPerformer(String cacheName,
 ArrayBlockingQueue<PersistentUpdate> batchingQueue)

Method Details

registerChange

public void registerChange(Map.Entry<K,SessionUpdatesList<V>> entry,
 MergedUpdate<V> merged)

Specified by:

registerChange in interface SessionChangesPerformer<K,V extends SessionEntity>

applyChanges

public void applyChanges()

Specified by:

applyChanges in interface SessionChangesPerformer<K,V extends SessionEntity>

applyChangesSynchronously

public void applyChangesSynchronously(KeycloakSession session)