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