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 and Description
static ClientCacheFailoverEvent	FAILOVER_EVENT_SINGLETON

Method Summary

Modifier and Type	Method and Description
static ClientEventDispatcher	create(AddClientListenerOperation op, SocketAddress address, Runnable cleanup)
CompletableFuture<Short>	executeFailover()
static Map<Class<? extends Annotation>,List<org.infinispan.client.hotrod.event.impl.ClientEventDispatcher.ClientListenerInvocation>>	findMethods(Object listener)
protected DataFormat	getDataFormat()
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 Detail

FAILOVER_EVENT_SINGLETON

public static final ClientCacheFailoverEvent FAILOVER_EVENT_SINGLETON

Method Detail

create

public static ClientEventDispatcher create(AddClientListenerOperation op,
                                           SocketAddress address,
                                           Runnable cleanup)

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<Short> executeFailover()

Specified by:

executeFailover in class EventDispatcher<ClientEvent>

invokeFailoverEvent

protected void invokeFailoverEvent()

Overrides:

invokeFailoverEvent in class EventDispatcher<ClientEvent>

getDataFormat

protected DataFormat getDataFormat()