Package org.infinispan.client.hotrod.event.impl

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

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. Use allowList() instead.

Methods inherited from class java.lang.Object

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

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)

getListeners

public Set<Object> getListeners(String cacheName)

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.

Use allowList() instead. To be removed in 14.0.

channelFactory

public org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory()