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

Field Summary

Fields

Modifier and Type	Field	Description
static final int	UPDATE_BASE_INTERVAL_MILLIS
static final Duration	UPDATE_TIMEOUT

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

Field Details

UPDATE_TIMEOUT

public static final Duration UPDATE_TIMEOUT

UPDATE_BASE_INTERVAL_MILLIS

public static final int UPDATE_BASE_INTERVAL_MILLIS

See Also:

• Constant Field Values

Constructor Details

PersistentSessionsWorker

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

Method Details

start

public void start()

stop

public void stop()