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	setJTAPolicy (JTAPolicy policy)

限定公開メンバ関数
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

org.keycloak.models.KeycloakTransactionを実装しています。

                        {
        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

org.keycloak.models.KeycloakTransactionを実装しています。

                         {
        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

org.keycloak.models.KeycloakTransactionManagerを実装しています。

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

        transactions.add(transaction);
    }

enlistAfterCompletion()

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

inline

org.keycloak.models.KeycloakTransactionManagerを実装しています。

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

        afterCompletion.add(transaction);
    }

enlistPrepare()

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

inline

org.keycloak.models.KeycloakTransactionManagerを実装しています。

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

        prepare.add(transaction);
    }

getJTAPolicy()

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

inline

org.keycloak.models.KeycloakTransactionManagerを実装しています。

                                    {
        return jtaPolicy;
    }

getRollbackOnly()

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

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                                     {
        if (rollback) {
            return true;
        }

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

        return false;
    }

isActive()

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

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                              {
        return active;
    }

rollback() [1/2]

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

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                           {
        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() [1/2]

void org.keycloak.models.KeycloakTransactionManager.setJTAPolicy ( JTAPolicy  policy )

inherited

setJTAPolicy() [2/2]

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

inline

                                               {
        jtaPolicy = policy;

    }

setRollbackOnly()

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

inline

org.keycloak.models.KeycloakTransactionを実装しています。

                                  {
        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/src/keycloak/src/main/java/org/keycloak/services/DefaultKeycloakTransactionManager.java