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(Marshaller marshaller, org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory, Configuration configuration)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description void
addDispatcher(EventDispatcher<?> dispatcher)
ClassAllowList
allowList()
org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory
channelFactory()
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)
Marshaller
marshaller()
EventDispatcher<?>
removeClientListener(byte[] listenerId)
void
startClientListener(byte[] listenerId)
void
stop()
ClassAllowList
whitelist()
Deprecated.UseallowList()
instead.
-
-
-
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(Marshaller marshaller, org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory, Configuration configuration)
-
-
Method Detail
-
marshaller
public 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)
-
allowList
public ClassAllowList allowList()
-
whitelist
@Deprecated public ClassAllowList whitelist()
Deprecated.UseallowList()
instead. To be removed in 14.0.
-
channelFactory
public org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory()
-
-