Class ClientListenerNotifier

java.lang.Object
org.infinispan.client.hotrod.event.impl.ClientListenerNotifier

public class ClientListenerNotifier extends Object
Author:
Galder ZamarreƱo
  • Field Details

  • 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()