org.infinispan.client.hotrod.event

Class ClientListenerNotifier

java.lang.Object

org.infinispan.client.hotrod.event.ClientListenerNotifier

public class ClientListenerNotifier
extends Object

Author:

Galder Zamarreño

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClientListenerNotifier(ExecutorService executor, Codec codec, Marshaller marshaller, TransportFactory transportFactory)

Method Summary

Modifier and Type	Method and Description
void	addClientListener(AddClientListenerOperation op)
static ClientListenerNotifier	create(Codec codec, Marshaller marshaller, TransportFactory transportFactory)
void	failoverClientListener(byte[] listenerId)
void	failoverClientListeners(Set<SocketAddress> failedServers)
byte[]	findListenerId(Object listener)
Map<Class<? extends Annotation>,List<org.infinispan.client.hotrod.event.ClientListenerNotifier.ClientListenerInvocation>>	findMethods(Object listener)
Transport	findTransport(byte[] listenerId)
Set<Object>	getListeners(byte[] cacheName)
Marshaller	getMarshaller()
void	invokeEvent(byte[] listenerId, ClientEvent clientEvent)
boolean	isListenerConnected(byte[] listenerId)
void	removeClientListener(byte[] listenerId)
void	startClientListener(byte[] listenerId)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientListenerNotifier

protected ClientListenerNotifier(ExecutorService executor,
                                 Codec codec,
                                 Marshaller marshaller,
                                 TransportFactory transportFactory)

Method Detail

create

public static ClientListenerNotifier create(Codec codec,
                                            Marshaller marshaller,
                                            TransportFactory transportFactory)

getMarshaller

public Marshaller getMarshaller()

addClientListener

public void addClientListener(AddClientListenerOperation op)

failoverClientListeners

public void failoverClientListeners(Set<SocketAddress> failedServers)

failoverClientListener

public void failoverClientListener(byte[] listenerId)

startClientListener

public void startClientListener(byte[] listenerId)

removeClientListener

public void removeClientListener(byte[] listenerId)

findListenerId

public byte[] findListenerId(Object listener)

isListenerConnected

public boolean isListenerConnected(byte[] listenerId)

findTransport

public Transport findTransport(byte[] listenerId)

findMethods

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

getListeners

public Set<Object> getListeners(byte[] cacheName)

stop

public void stop()

invokeEvent

public void invokeEvent(byte[] listenerId,
                        ClientEvent clientEvent)