org.keycloak.services.DefaultKeycloakTransactionManager クラス

org.keycloak.services.DefaultKeycloakTransactionManager の継承関係図

org.keycloak.services.DefaultKeycloakTransactionManager 連携図

公開メンバ関数
	DefaultKeycloakTransactionManager (KeycloakSession session)
void	enlist (KeycloakTransaction transaction)
void	enlistAfterCompletion (KeycloakTransaction transaction)
void	enlistPrepare (KeycloakTransaction transaction)
JTAPolicy	getJTAPolicy ()
void	setJTAPolicy (JTAPolicy policy)
void	begin ()
void	commit ()
void	rollback ()
void	setRollbackOnly ()
boolean	getRollbackOnly ()
boolean	isActive ()

限定公開メンバ関数
void	rollback (RuntimeException exception)

限定公開変数類
boolean	completed

非公開変数類
List< KeycloakTransaction >	prepare = new LinkedList<KeycloakTransaction>()
List< KeycloakTransaction >	transactions = new LinkedList<KeycloakTransaction>()
List< KeycloakTransaction >	afterCompletion = new LinkedList<KeycloakTransaction>()
boolean	active
boolean	rollback
KeycloakSession	session
JTAPolicy	jtaPolicy = JTAPolicy.REQUIRES_NEW

静的非公開変数類
static final Logger	logger = Logger.getLogger(DefaultKeycloakTransactionManager.class)

詳解

著者

Stian Thorgersen

構築子と解体子

DefaultKeycloakTransactionManager()

org.keycloak.services.DefaultKeycloakTransactionManager.DefaultKeycloakTransactionManager ( KeycloakSession  session )

inline

                                                                      {
        this.session = session;
    }

関数詳解

begin()

void org.keycloak.services.DefaultKeycloakTransactionManager.begin ( )

inline

                        {
        if (active) {
             throw new IllegalStateException("Transaction already active");
        }

        completed = false;

        if (jtaPolicy == JTAPolicy.REQUIRES_NEW) {
            JtaTransactionManagerLookup jtaLookup = session.getProvider(JtaTransactionManagerLookup.class);
            if (jtaLookup != null) {
                TransactionManager tm = jtaLookup.getTransactionManager();
                if (tm != null) {
                   enlist(new JtaTransactionWrapper(session.getKeycloakSessionFactory(), tm));
                }
            }
        }

        for (KeycloakTransaction tx : transactions) {
            tx.begin();
        }

        active = true;
    }

commit()

void org.keycloak.services.DefaultKeycloakTransactionManager.commit ( )

inline

                         {
        if (completed) {
            return;
        } else {
            completed = true;
        }

        RuntimeException exception = null;
        for (KeycloakTransaction tx : prepare) {
            try {
                tx.commit();
            } catch (RuntimeException e) {
                exception = exception == null ? e : exception;
            }
        }
        if (exception != null) {
            rollback(exception);
            return;
        }
        for (KeycloakTransaction tx : transactions) {
            try {
                tx.commit();
            } catch (RuntimeException e) {
                exception = exception == null ? e : exception;
            }
        }

        // Don't commit "afterCompletion" if commit of some main transaction failed
        if (exception == null) {
            for (KeycloakTransaction tx : afterCompletion) {
                try {
                    tx.commit();
                } catch (RuntimeException e) {
                    exception = exception == null ? e : exception;
                }
            }
        } else {
            for (KeycloakTransaction tx : afterCompletion) {
                try {
                    tx.rollback();
                } catch (RuntimeException e) {
                    ServicesLogger.LOGGER.exceptionDuringRollback(e);
                }
            }
        }

        active = false;
        if (exception != null) {
            throw exception;
        }
    }

enlist()

void org.keycloak.services.DefaultKeycloakTransactionManager.enlist ( KeycloakTransaction  transaction )

inline

                                                        {
        if (active && !transaction.isActive()) {
            transaction.begin();
        }

        transactions.add(transaction);
    }

enlistAfterCompletion()

void org.keycloak.services.DefaultKeycloakTransactionManager.enlistAfterCompletion ( KeycloakTransaction  transaction )

inline

                                                                       {
        if (active && !transaction.isActive()) {
            transaction.begin();
        }

        afterCompletion.add(transaction);
    }

enlistPrepare()

void org.keycloak.services.DefaultKeycloakTransactionManager.enlistPrepare ( KeycloakTransaction  transaction )

inline

                                                               {
        if (active && !transaction.isActive()) {
            transaction.begin();
        }

        prepare.add(transaction);
    }

getJTAPolicy()

JTAPolicy org.keycloak.services.DefaultKeycloakTransactionManager.getJTAPolicy ( )

inline

                                    {
        return jtaPolicy;
    }

getRollbackOnly()

boolean org.keycloak.services.DefaultKeycloakTransactionManager.getRollbackOnly ( )

inline

                                     {
        if (rollback) {
            return true;
        }

        for (KeycloakTransaction tx : transactions) {
            if (tx.getRollbackOnly()) {
                return true;
            }
        }

        return false;
    }

isActive()

boolean org.keycloak.services.DefaultKeycloakTransactionManager.isActive ( )

inline

                              {
        return active;
    }

rollback() [1/2]

void org.keycloak.services.DefaultKeycloakTransactionManager.rollback ( )

inline

                           {
        if (completed) {
            return;
        } else {
            completed = true;
        }

        RuntimeException exception = null;
        rollback(exception);
    }

rollback() [2/2]

void org.keycloak.services.DefaultKeycloakTransactionManager.rollback ( RuntimeException  exception )

inlineprotected

                                                        {
        for (KeycloakTransaction tx : transactions) {
            try {
                tx.rollback();
            } catch (RuntimeException e) {
                exception = exception != null ? e : exception;
            }
        }
        for (KeycloakTransaction tx : afterCompletion) {
            try {
                tx.rollback();
            } catch (RuntimeException e) {
                exception = exception != null ? e : exception;
            }
        }
        active = false;
        if (exception != null) {
            throw exception;
        }
    }

setJTAPolicy()

void org.keycloak.services.DefaultKeycloakTransactionManager.setJTAPolicy ( JTAPolicy  policy )

inline

                                               {
        jtaPolicy = policy;

    }

setRollbackOnly()

void org.keycloak.services.DefaultKeycloakTransactionManager.setRollbackOnly ( )

inline

                                  {
        rollback = true;
    }

メンバ詳解

active

boolean org.keycloak.services.DefaultKeycloakTransactionManager.active

private

afterCompletion

List<KeycloakTransaction> org.keycloak.services.DefaultKeycloakTransactionManager.afterCompletion = new LinkedList<KeycloakTransaction>()

private

completed

boolean org.keycloak.services.DefaultKeycloakTransactionManager.completed

protected

jtaPolicy

JTAPolicy org.keycloak.services.DefaultKeycloakTransactionManager.jtaPolicy = JTAPolicy.REQUIRES_NEW

private

logger

final Logger org.keycloak.services.DefaultKeycloakTransactionManager.logger = Logger.getLogger(DefaultKeycloakTransactionManager.class)

staticprivate

prepare

List<KeycloakTransaction> org.keycloak.services.DefaultKeycloakTransactionManager.prepare = new LinkedList<KeycloakTransaction>()

private

rollback

boolean org.keycloak.services.DefaultKeycloakTransactionManager.rollback

private

session

KeycloakSession org.keycloak.services.DefaultKeycloakTransactionManager.session

private

transactions

List<KeycloakTransaction> org.keycloak.services.DefaultKeycloakTransactionManager.transactions = new LinkedList<KeycloakTransaction>()

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/rest-service/src/services/src/main/java/org/keycloak/services/DefaultKeycloakTransactionManager.java