org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent > クラステンプレート

org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent > の継承関係図

org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent > 連携図

公開メンバ関数
	AbstractUserSessionClusterListener (KeycloakSessionFactory sessionFactory)
void	eventReceived (ClusterEvent event)

限定公開メンバ関数
abstract void	eventReceived (KeycloakSession session, InfinispanUserSessionProvider provider, SE sessionEvent)

非公開メンバ関数
boolean	shouldResendEvent (KeycloakSession session, SessionClusterEvent event)

非公開変数類
final KeycloakSessionFactory	sessionFactory

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

詳解

著者

Marek Posolda

構築子と解体子

AbstractUserSessionClusterListener()

org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent >.AbstractUserSessionClusterListener ( KeycloakSessionFactory  sessionFactory )

inline

                                                                                     {
        this.sessionFactory = sessionFactory;
    }

関数詳解

eventReceived() [1/2]

void org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent >.eventReceived ( ClusterEvent  event )

inline

org.keycloak.cluster.ClusterListenerを実装しています。

                                                  {
        KeycloakModelUtils.runJobInTransaction(sessionFactory, (KeycloakSession session) -> {
            InfinispanUserSessionProvider provider = (InfinispanUserSessionProvider) session.getProvider(UserSessionProvider.class, InfinispanUserSessionProviderFactory.PROVIDER_ID);
            SE sessionEvent = (SE) event;

            boolean shouldResendEvent = shouldResendEvent(session, sessionEvent);

            if (log.isDebugEnabled()) {
                log.debugf("Received user session event '%s'. Should resend event: %b", sessionEvent.toString(), shouldResendEvent);
            }

            eventReceived(session, provider, sessionEvent);

            if (shouldResendEvent) {
                session.getProvider(ClusterProvider.class).notify(sessionEvent.getEventKey(), event, true, ClusterProvider.DCNotify.ALL_BUT_LOCAL_DC);
            }

        });
    }

eventReceived() [2/2]

abstract void org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent >.eventReceived ( KeycloakSession  session, InfinispanUserSessionProvider  provider, SE  sessionEvent  )

abstractprotected

shouldResendEvent()

boolean org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent >.shouldResendEvent ( KeycloakSession  session, SessionClusterEvent  event  )

inlineprivate

                                                                                          {
        if (!event.isResendingEvent()) {
            return false;
        }

        // Just the initiator will re-send the event after receiving it
        TopologyInfo topology = InfinispanUtil.getTopologyInfo(session);
        String myNode = topology.getMyNodeName();
        String mySite = topology.getMySiteName();
        return (event.getNodeId() != null && event.getNodeId().equals(myNode) && event.getSiteId() != null && event.getSiteId().equals(mySite));
    }

メンバ詳解

log

final Logger org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent >.log = Logger.getLogger(AbstractUserSessionClusterListener.class)

staticprivate

sessionFactory

final KeycloakSessionFactory org.keycloak.models.sessions.infinispan.events.AbstractUserSessionClusterListener< SE extends SessionClusterEvent >.sessionFactory

private

---

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

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