org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener クラス

org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener 連携図

公開メンバ関数
	HotRodListener (RemoteCache< Object, Object > remoteCache)
void	created (ClientCacheEntryCreatedEvent event)
void	updated (ClientCacheEntryModifiedEvent event)
void	removed (ClientCacheEntryRemovedEvent event)

非公開メンバ関数
void	hotrodEventReceived (String key)

非公開変数類
final RemoteCache< Object, Object >	remoteCache

詳解

構築子と解体子

HotRodListener()

org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener.HotRodListener ( RemoteCache< Object, Object >  remoteCache )

inline

                                                                       {
            this.remoteCache = remoteCache;
        }

関数詳解

created()

void org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener.created ( ClientCacheEntryCreatedEvent  event )

inline

                                                                {
            String key = event.getKey().toString();
            hotrodEventReceived(key);
        }

hotrodEventReceived()

void org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener.hotrodEventReceived ( String  key )

inlineprivate

                                                     {
            // TODO: Look at CacheEventConverter stuff to possibly include value in the event and avoid additional remoteCache request
            try {
                listenersExecutor.submit(() -> {

                    Object value = remoteCache.get(key);
                    eventReceived(key, (Serializable) value);

                });
            } catch (RejectedExecutionException ree) {
                logger.errorf("Rejected submitting of the event for key: %s. Value: %s, Server going to shutdown or pool exhausted. Pool: %s", key, workCache.get(key), listenersExecutor.toString());
                throw ree;
            }
        }

removed()

void org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener.removed ( ClientCacheEntryRemovedEvent  event )

inline

                                                                {
            String key = event.getKey().toString();
            taskFinished(key, true);
        }

updated()

void org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener.updated ( ClientCacheEntryModifiedEvent  event )

inline

                                                                 {
            String key = event.getKey().toString();
            hotrodEventReceived(key);
        }

メンバ詳解

remoteCache

final RemoteCache<Object, Object> org.keycloak.cluster.infinispan.InfinispanNotificationsManager.HotRodListener.remoteCache

private

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/cluster/infinispan/InfinispanNotificationsManager.java