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 final AtomicInteger	counter
static final 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, for removal: This API element is subject to removal in a future version. Use allowList() instead.

Methods inherited from class java.lang.Object

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

Field Details

counter

public static final AtomicInteger counter

RECONNECT_PERIOD

public static final int RECONNECT_PERIOD

See Also:

• Constant Field Values

Constructor Details

ClientListenerNotifier

public ClientListenerNotifier(Marshaller marshaller,
 org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory channelFactory,
 Configuration configuration)

Method Details

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(forRemoval=true)
public ClassAllowList whitelist()

Deprecated, for removal: This API element is subject to removal in a future version.

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

channelFactory

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