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

Class DefaultInfinispanTransactionProvider

java.lang.Object

org.keycloak.models.AbstractKeycloakTransaction

org.keycloak.models.sessions.infinispan.transaction.DefaultInfinispanTransactionProvider

All Implemented Interfaces:

KeycloakTransaction, InfinispanTransactionProvider, Provider

public class DefaultInfinispanTransactionProvider
extends AbstractKeycloakTransaction
implements InfinispanTransactionProvider

A KeycloakTransaction that collects NonBlockingTransaction to commit/rollback in a non-blocking fashion.

This class is not thread-safe.

Nested Class Summary

Nested classes/interfaces inherited from class org.keycloak.models.AbstractKeycloakTransaction

AbstractKeycloakTransaction.TransactionState

Field Summary

Fields inherited from class org.keycloak.models.AbstractKeycloakTransaction

state

Constructor Summary

Constructors

Constructor	Description
DefaultInfinispanTransactionProvider(KeycloakSession session)

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	commitImpl()
void	prepareStep()	During the prepare phase of the current transaction, try to move all database writes to the current JTA transaction.
void	registerTransaction(NonBlockingTransaction transaction)	Registers a new NonBlockingTransaction.
protected void	rollbackImpl()

Methods inherited from class org.keycloak.models.AbstractKeycloakTransaction

begin, beginImpl, commit, getRollbackOnly, getState, isActive, rollback, setRollbackOnly

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultInfinispanTransactionProvider

public DefaultInfinispanTransactionProvider(KeycloakSession session)

Method Details

registerTransaction

public void registerTransaction(NonBlockingTransaction transaction)

Description copied from interface: InfinispanTransactionProvider

Registers a new NonBlockingTransaction.

Specified by:

registerTransaction in interface InfinispanTransactionProvider

Parameters:

transaction - The NonBlockingTransaction transaction instance.

close

public void close()

Specified by:

close in interface Provider

commitImpl

protected void commitImpl()

Specified by:

commitImpl in class AbstractKeycloakTransaction

prepareStep

public void prepareStep()

During the prepare phase of the current transaction, try to move all database writes to the current JTA transaction.

If this is possible, this will prevent additional reads from the database and a separate transaction. Only if rows are modified concurrently, this might fail, which should be a rare exception.

rollbackImpl

protected void rollbackImpl()

Specified by:

rollbackImpl in class AbstractKeycloakTransaction