org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction クラス

org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction の継承関係図

org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction 連携図

クラス
class	DCEventContext

公開メンバ関数
	SessionEventsSenderTransaction (KeycloakSession session)
void	addEvent (SessionClusterEvent event, ClusterProvider.DCNotify dcNotify)
void	begin ()
void	commit ()
void	rollback ()
void	setRollbackOnly ()
boolean	getRollbackOnly ()
boolean	isActive ()
TransactionState	getState ()

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

限定公開メンバ関数
void	commitImpl ()
void	rollbackImpl ()

限定公開変数類
TransactionState	state = TransactionState.NOT_STARTED

非公開変数類
final KeycloakSession	session
final List< DCEventContext >	sessionEvents = new LinkedList<>()

詳解

Postpone sending notifications of session events to the commit of Keycloak transaction

著者

Marek Posolda

構築子と解体子

SessionEventsSenderTransaction()

org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction.SessionEventsSenderTransaction ( KeycloakSession  session )

inline

                                                                   {
        this.session = session;
    }

関数詳解

addEvent()

void org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction.addEvent ( SessionClusterEvent  event, ClusterProvider.DCNotify  dcNotify  )

inline

                                                                                       {
        sessionEvents.add(new DCEventContext(dcNotify, event));
    }

begin()

void org.keycloak.models.AbstractKeycloakTransaction.begin ( )

inlineinherited

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

                        {
        if (state != TransactionState.NOT_STARTED) {
            throw new IllegalStateException("Transaction already started");
        }

        state = TransactionState.STARTED;
    }

commit()

void org.keycloak.models.AbstractKeycloakTransaction.commit ( )

inlineinherited

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

                         {
        if (state != TransactionState.STARTED) {
            throw new IllegalStateException("Transaction in illegal state for commit: " + state);
        }

        commitImpl();

        state = TransactionState.FINISHED;
    }

commitImpl()

void org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction.commitImpl ( )

inlineprotected

                                {
        ClusterProvider cluster = session.getProvider(ClusterProvider.class);

        // TODO bulk notify (send whole list instead of separate events?)
        for (DCEventContext entry : sessionEvents) {
            cluster.notify(entry.event.getEventKey(), entry.event, false, entry.dcNotify);
        }
    }

getRollbackOnly()

boolean org.keycloak.models.AbstractKeycloakTransaction.getRollbackOnly ( )

inlineinherited

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

                                     {
        return state == TransactionState.ROLLBACK_ONLY;
    }

getState()

TransactionState org.keycloak.models.AbstractKeycloakTransaction.getState ( )

inlineinherited

                                       {
        return state;
    }

isActive()

boolean org.keycloak.models.AbstractKeycloakTransaction.isActive ( )

inlineinherited

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

                              {
        return state == TransactionState.STARTED || state == TransactionState.ROLLBACK_ONLY;
    }

rollback()

void org.keycloak.models.AbstractKeycloakTransaction.rollback ( )

inlineinherited

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

                           {
        if (state != TransactionState.STARTED && state != TransactionState.ROLLBACK_ONLY) {
            throw new IllegalStateException("Transaction in illegal state for rollback: " + state);
        }

        rollbackImpl();

        state = TransactionState.FINISHED;
    }

rollbackImpl()

void org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction.rollbackImpl ( )

inlineprotected

                                  {

    }

setRollbackOnly()

void org.keycloak.models.AbstractKeycloakTransaction.setRollbackOnly ( )

inlineinherited

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

                                  {
        state = TransactionState.ROLLBACK_ONLY;
    }

メンバ詳解

logger

final Logger org.keycloak.models.AbstractKeycloakTransaction.logger = Logger.getLogger(AbstractKeycloakTransaction.class)

staticinherited

session

final KeycloakSession org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction.session

private

sessionEvents

final List<DCEventContext> org.keycloak.models.sessions.infinispan.events.SessionEventsSenderTransaction.sessionEvents = new LinkedList<>()

private

state

TransactionState org.keycloak.models.AbstractKeycloakTransaction.state = TransactionState.NOT_STARTED

protectedinherited

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/sessions/infinispan/events/SessionEventsSenderTransaction.java