Class ClientListenerNotifier


  • public class ClientListenerNotifier
    extends Object
    Author:
    Galder ZamarreƱo
    • 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()