Package org.infinispan.client.hotrod.event.impl

Class ClientEventDispatcher

java.lang.Object

org.infinispan.client.hotrod.event.impl.EventDispatcher<ClientEvent>

org.infinispan.client.hotrod.event.impl.ClientEventDispatcher

public final class ClientEventDispatcher
extends EventDispatcher<ClientEvent>

Field Summary

Fields

Modifier and Type	Field	Description
static final ClientCacheFailoverEvent	FAILOVER_EVENT_SINGLETON

Method Summary

Modifier and Type	Method	Description
static ClientEventDispatcher	create(org.infinispan.client.hotrod.impl.operations.ClientListenerOperation op, SocketAddress address, Runnable cleanup, InternalRemoteCache<?,?> remoteCache)
CompletableFuture<Void>	executeFailover()
static Map<Class<? extends Annotation>,List<org.infinispan.client.hotrod.event.impl.ClientEventDispatcher.ClientListenerInvocation>>	findMethods(Object listener)
void	invokeEvent(ClientEvent clientEvent)
protected void	invokeFailoverEvent()

Methods inherited from class org.infinispan.client.hotrod.event.impl.EventDispatcher

address, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Field Details

FAILOVER_EVENT_SINGLETON

public static final ClientCacheFailoverEvent FAILOVER_EVENT_SINGLETON

Method Details

create

public static ClientEventDispatcher create(org.infinispan.client.hotrod.impl.operations.ClientListenerOperation op,
 SocketAddress address,
 Runnable cleanup,
 InternalRemoteCache<?,?> remoteCache)

findMethods

public static Map<Class<? extends Annotation>,List<org.infinispan.client.hotrod.event.impl.ClientEventDispatcher.ClientListenerInvocation>> findMethods(Object listener)

invokeEvent

public void invokeEvent(ClientEvent clientEvent)

Specified by:

invokeEvent in class EventDispatcher<ClientEvent>

executeFailover

public CompletableFuture<Void> executeFailover()

Specified by:

executeFailover in class EventDispatcher<ClientEvent>

invokeFailoverEvent

protected void invokeFailoverEvent()

Overrides:

invokeFailoverEvent in class EventDispatcher<ClientEvent>