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>
public class JpaChangesPerformer<K,V extends SessionEntity> extends Object

  • Constructor Details

    • JpaChangesPerformer

      public JpaChangesPerformer(String cacheName)

  • Method Details

    • registerChange

      public void registerChange(Map.Entry<K,SessionUpdatesList<V>> entry, MergedUpdate<V> merged)
      It queues a database write to be applied at a future invocation.
      Parameters:
      entry - The Map.Entry with the ID and the session.
      merged - The MergedUpdate to be applied to the existing session.

    • write

      public void write(KeycloakSession session)
      Applies all the pending write operation into the database.
      Parameters:
      session - The KeycloakSession to access the database.

    • clear

      public void clear()
      Clears any pending blocking changes.