Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.infinispan.client.hotrod.impl.operations;
Remove client listener operation. In order to avoid issues with concurrent event consumption, removing client listener operation is sent in a separate connection to the one used for event consumption, but it must go to the same node where the listener has been added.

Galder ZamarreƱo
   private final Object listener;
   protected final TransportFactory transportFactory;
   protected RemoveClientListenerOperation(Codec codecTransportFactory transportFactory,
         byte[] cacheNameAtomicInteger topologyIdFlag[] flags,
         ClientListenerNotifier listenerNotifierObject listener) {
      this. = transportFactory;
      this. = listenerNotifier;
      this. = listener;
   public Object execute() {
      byte[] listenerId = .findListenerId();
      if (listenerId != null) {
         SocketAddress address = .findTransport(listenerId).getRemoteSocketAddress();
         Transport transport = .getAddressTransport(address);
         try {
            HeaderParams params = writeHeader(transport);
            short status = readHeaderAndValidate(transportparams);
            if (status == )
         } finally {
      return null;
New to GrepCode? Check out our FAQ X