Package org.keycloak.cluster.infinispan.remote

Class RemoteInfinispanNotificationManager

java.lang.Object

org.keycloak.cluster.infinispan.remote.RemoteInfinispanNotificationManager

public class RemoteInfinispanNotificationManager
extends Object

Constructor Summary

Constructors

Constructor	Description
RemoteInfinispanNotificationManager(Executor executor, org.infinispan.client.hotrod.RemoteCache<String,Object> workCache, NodeInfo nodeInfo)

Method Summary

Modifier and Type	Method	Description
void	addClientListener()
String	getMyNodeName()
void	notify(String taskKey, Collection<? extends ClusterEvent> events, boolean ignoreSender, ClusterProvider.DCNotify dcNotify)
void	onEntryRemoved(org.infinispan.client.hotrod.event.ClientCacheEntryCustomEvent<byte[]> event)
void	onEntryUpdated(org.infinispan.client.hotrod.event.ClientCacheEntryCustomEvent<byte[]> event)
void	registerListener(String taskKey, ClusterListener task)
TaskCallback	registerTaskCallback(String taskKey, TaskCallback callback)
void	removeClientListener()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RemoteInfinispanNotificationManager

public RemoteInfinispanNotificationManager(Executor executor,
 org.infinispan.client.hotrod.RemoteCache<String,Object> workCache,
 NodeInfo nodeInfo)

Method Details

addClientListener

public void addClientListener()

removeClientListener

public void removeClientListener()

registerListener

public void registerListener(String taskKey,
 ClusterListener task)

registerTaskCallback

public TaskCallback registerTaskCallback(String taskKey,
 TaskCallback callback)

notify

public void notify(String taskKey,
 Collection<? extends ClusterEvent> events,
 boolean ignoreSender,
 ClusterProvider.DCNotify dcNotify)

getMyNodeName

public String getMyNodeName()

onEntryUpdated

public void onEntryUpdated(org.infinispan.client.hotrod.event.ClientCacheEntryCustomEvent<byte[]> event)

onEntryRemoved

public void onEntryRemoved(org.infinispan.client.hotrod.event.ClientCacheEntryCustomEvent<byte[]> event)