public class ClientListenerNotifier extends Object
Constructor and Description |
---|
ClientListenerNotifier(ExecutorService executor,
Codec codec,
Marshaller marshaller) |
Modifier and Type | Method and Description |
---|---|
void |
addClientListener(AddClientListenerOperation op) |
void |
failoverClientListeners(Set failedServers) |
byte[] |
findListenerId(Object listener) |
Transport |
findTransport(byte[] listenerId) |
Set |
getListeners(byte[] cacheName) |
Marshaller |
getMarshaller() |
void |
invokeEvent(byte[] listenerId,
ClientEvent clientEvent) |
boolean |
isListenerConnected(Object listener) |
void |
removeClientListener(byte[] listenerId) |
void |
startClientListener(byte[] listenerId) |
void |
stop() |
public ClientListenerNotifier(ExecutorService executor, Codec codec, Marshaller marshaller)
public Marshaller getMarshaller()
public void addClientListener(AddClientListenerOperation op)
public void failoverClientListeners(Set failedServers)
public void startClientListener(byte[] listenerId)
public void removeClientListener(byte[] listenerId)
public byte[] findListenerId(Object listener)
public boolean isListenerConnected(Object listener)
public Transport findTransport(byte[] listenerId)
public Set getListeners(byte[] cacheName)
public void stop()
public void invokeEvent(byte[] listenerId, ClientEvent clientEvent)
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.