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

Class PersistentSessionsWorker

java.lang.Object

org.keycloak.models.sessions.infinispan.changes.PersistentSessionsWorker

public class PersistentSessionsWorker
extends Object

Run one thread per session type and drain the queues once there is an entry. Will batch entries if possible.

Author:

Alexander Schwartz

Constructor Summary

Constructors

Constructor	Description
PersistentSessionsWorker(KeycloakSessionFactory factory, ArrayBlockingQueue<PersistentUpdate> asyncQueuePersistentUpdate, int maxBatchSize)

Method Summary

Modifier and Type	Method	Description
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

PersistentSessionsWorker

public PersistentSessionsWorker(KeycloakSessionFactory factory,
 ArrayBlockingQueue<PersistentUpdate> asyncQueuePersistentUpdate,
 int maxBatchSize)

Method Details

start

public void start()

stop

public void stop()