Class ClientListenerNotifier
- java.lang.Object
-
- org.infinispan.client.hotrod.event.impl.ClientListenerNotifier
-
public class ClientListenerNotifier extends Object
- Author:
- Galder ZamarreƱo
-
-
Field Summary
Fields Modifier and Type Field Description static AtomicInteger
counter
static int
RECONNECT_PERIOD
-
Constructor Summary
Constructors Constructor Description ClientListenerNotifier(org.infinispan.client.hotrod.impl.protocol.Codec codec, org.infinispan.commons.marshall.Marshaller marshaller, org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory, Configuration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addDispatcher(EventDispatcher<?> dispatcher)
org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory
channelFactory()
org.infinispan.client.hotrod.impl.protocol.Codec
codec()
void
failoverClientListener(byte[] listenerId)
void
failoverListeners(Set<SocketAddress> failedServers)
SocketAddress
findAddress(byte[] listenerId)
byte[]
findListenerId(Object listener)
DataFormat
getCacheDataFormat(byte[] listenerId)
Set<Object>
getListeners(String cacheName)
<T> void
invokeEvent(byte[] listenerId, T event)
boolean
isListenerConnected(byte[] listenerId)
org.infinispan.commons.marshall.Marshaller
marshaller()
EventDispatcher<?>
removeClientListener(byte[] listenerId)
void
startClientListener(byte[] listenerId)
void
stop()
org.infinispan.commons.configuration.ClassWhiteList
whitelist()
-
-
-
Field Detail
-
counter
public static final AtomicInteger counter
-
RECONNECT_PERIOD
public static final int RECONNECT_PERIOD
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ClientListenerNotifier
public ClientListenerNotifier(org.infinispan.client.hotrod.impl.protocol.Codec codec, org.infinispan.commons.marshall.Marshaller marshaller, org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory, Configuration configuration)
-
-
Method Detail
-
marshaller
public org.infinispan.commons.marshall.Marshaller marshaller()
-
addDispatcher
public void addDispatcher(EventDispatcher<?> dispatcher)
-
failoverListeners
public void failoverListeners(Set<SocketAddress> failedServers)
-
failoverClientListener
public void failoverClientListener(byte[] listenerId)
-
startClientListener
public void startClientListener(byte[] listenerId)
-
removeClientListener
public EventDispatcher<?> removeClientListener(byte[] listenerId)
-
findListenerId
public byte[] findListenerId(Object listener)
-
isListenerConnected
public boolean isListenerConnected(byte[] listenerId)
-
findAddress
public SocketAddress findAddress(byte[] listenerId)
-
stop
public void stop()
-
invokeEvent
public <T> void invokeEvent(byte[] listenerId, T event)
-
getCacheDataFormat
public DataFormat getCacheDataFormat(byte[] listenerId)
-
codec
public org.infinispan.client.hotrod.impl.protocol.Codec codec()
-
whitelist
public org.infinispan.commons.configuration.ClassWhiteList whitelist()
-
channelFactory
public org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory()
-
-