org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener クラス

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener の継承関係図

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener 連携図

公開メンバ関数
	LastSessionRefreshListener (KeycloakSession session, Cache< String, SessionEntityWrapper< UserSessionEntity >> cache, boolean offline)
void	eventReceived (ClusterEvent event)

静的公開変数類
static final Logger	logger = Logger.getLogger(LastSessionRefreshListener.class)
static final String	IGNORE_REMOTE_CACHE_UPDATE = "IGNORE_REMOTE_CACHE_UPDATE"

限定公開メンバ関数
boolean	shouldUpdateLocalCache (String key)

非公開変数類
final boolean	offline
final KeycloakSessionFactory	sessionFactory
final Cache< String, SessionEntityWrapper< UserSessionEntity > >	cache
final TopologyInfo	topologyInfo

詳解

著者

Marek Posolda

構築子と解体子

LastSessionRefreshListener()

org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.LastSessionRefreshListener ( KeycloakSession  session, Cache< String, SessionEntityWrapper< UserSessionEntity >>  cache, boolean  offline  )

inline

                                                                                                                                              {
        this.sessionFactory = session.getKeycloakSessionFactory();
        this.cache = cache;
        this.offline = offline;

        this.topologyInfo = InfinispanUtil.getTopologyInfo(session);
    }

関数詳解

eventReceived()

void org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.eventReceived ( ClusterEvent  event )

inline

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

                                                  {
        Map<String, SessionData> lastSessionRefreshes = ((LastSessionRefreshEvent) event).getLastSessionRefreshes();

        if (logger.isDebugEnabled()) {
            logger.debugf("Received refreshes. Offline %b, refreshes: %s", offline, lastSessionRefreshes);
        }

        lastSessionRefreshes.entrySet().stream().forEach((entry) -> {
            String sessionId = entry.getKey();
            String realmId = entry.getValue().getRealmId();
            int lastSessionRefresh = entry.getValue().getLastSessionRefresh();

            // All nodes will receive the message. So ensure that each node updates just lastSessionRefreshes owned by him.
            if (shouldUpdateLocalCache(sessionId)) {
                KeycloakModelUtils.runJobInTransaction(sessionFactory, (kcSession) -> {

                    RealmModel realm = kcSession.realms().getRealm(realmId);
                    UserSessionModel userSession = offline ? kcSession.sessions().getOfflineUserSession(realm, sessionId) : kcSession.sessions().getUserSession(realm, sessionId);
                    if (userSession == null) {
                        logger.debugf("User session '%s' not available on node '%s' offline '%b'", sessionId, topologyInfo.getMyNodeName(), offline);
                    } else {
                        // Update just if lastSessionRefresh from event is bigger than ours
                        if (lastSessionRefresh > userSession.getLastSessionRefresh()) {

                            // Ensure that remoteCache won't be updated due to this
                            kcSession.setAttribute(IGNORE_REMOTE_CACHE_UPDATE, true);

                            userSession.setLastSessionRefresh(lastSessionRefresh);
                        }
                    }
                });
            }

        });
    }

shouldUpdateLocalCache()

boolean org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.shouldUpdateLocalCache ( String  key )

inlineprotected

                                                         {
        return topologyInfo.amIOwner(cache, key);
    }

メンバ詳解

cache

final Cache<String, SessionEntityWrapper<UserSessionEntity> > org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.cache

private

IGNORE_REMOTE_CACHE_UPDATE

final String org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.IGNORE_REMOTE_CACHE_UPDATE = "IGNORE_REMOTE_CACHE_UPDATE"

static

logger

final Logger org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.logger = Logger.getLogger(LastSessionRefreshListener.class)

static

offline

final boolean org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.offline

private

sessionFactory

final KeycloakSessionFactory org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.sessionFactory

private

topologyInfo

final TopologyInfo org.keycloak.models.sessions.infinispan.changes.sessions.LastSessionRefreshListener.topologyInfo

private

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/sessions/infinispan/changes/sessions/LastSessionRefreshListener.java