Package org.keycloak.models.sessions.infinispan.remote.transaction

Class UserSessionTransaction

java.lang.Object

org.keycloak.models.sessions.infinispan.remote.transaction.UserSessionTransaction

All Implemented Interfaces:

NonBlockingTransaction

public class UserSessionTransaction
extends Object
implements NonBlockingTransaction

A KeycloakTransaction implementation that wraps all the user and client session transactions.

This implementation commits all modifications asynchronously and concurrently in both user and client sessions transactions. Waits for all them to complete. This is an optimization to reduce the response time.

Constructor Summary

Constructors

Constructor	Description
UserSessionTransaction(UserSessionChangeLogTransaction userSessions, UserSessionChangeLogTransaction offlineUserSessions, ClientSessionChangeLogTransaction clientSessions, ClientSessionChangeLogTransaction offlineClientSessions)

Method Summary

Modifier and Type	Method	Description
void	asyncCommit(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage, Consumer<DatabaseUpdate> databaseUpdates)	Asynchronously commits the transaction.
void	asyncRollback(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage)	Asynchronously rollbacks the transaction.
ClientSessionChangeLogTransaction	getClientSessions(boolean offline)
UserSessionChangeLogTransaction	getUserSessions(boolean offline)
void	removeAllSessionByUserId(String realmId, String userId)
void	removeAllSessionsByRealmId(String realmId)
void	removeOnlineSessionsByRealmId(String realmId)
void	removeUserSessionById(String userSessionId, boolean offline)

Methods inherited from class java.lang.Object

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

Constructor Details

UserSessionTransaction

public UserSessionTransaction(UserSessionChangeLogTransaction userSessions,
 UserSessionChangeLogTransaction offlineUserSessions,
 ClientSessionChangeLogTransaction clientSessions,
 ClientSessionChangeLogTransaction offlineClientSessions)

Method Details

asyncCommit

public void asyncCommit(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage,
 Consumer<DatabaseUpdate> databaseUpdates)

Description copied from interface: NonBlockingTransaction

Asynchronously commits the transaction.

The implementation should not block the thread and add any (or none) CompletionStage into the stage.

Any blocking operation should be consumed by the databaseUpdates. It will be executed at a later instant.

Specified by:

asyncCommit in interface NonBlockingTransaction

Parameters:

stage - The AggregateCompletionStage to collect the CompletionStage.

databaseUpdates - The Consumer to use for blocking/database updates.

asyncRollback

public void asyncRollback(org.infinispan.commons.util.concurrent.AggregateCompletionStage<Void> stage)

Description copied from interface: NonBlockingTransaction

Asynchronously rollbacks the transaction.

The implementation should not block the thread and add any (or none) CompletionStage into the stage.

Specified by:

asyncRollback in interface NonBlockingTransaction

Parameters:

stage - The AggregateCompletionStage to collect the CompletionStage.

getClientSessions

public ClientSessionChangeLogTransaction getClientSessions(boolean offline)

getUserSessions

public UserSessionChangeLogTransaction getUserSessions(boolean offline)

removeAllSessionsByRealmId

public void removeAllSessionsByRealmId(String realmId)

removeOnlineSessionsByRealmId

public void removeOnlineSessionsByRealmId(String realmId)

removeAllSessionByUserId

public void removeAllSessionByUserId(String realmId,
 String userId)

removeUserSessionById

public void removeUserSessionById(String userSessionId,
 boolean offline)