     (channelRead0 [^ChannelHandlerContext ctx in]
       (info "Read0 Start " (Thread/currentThread)  " read-ch: " read-ch)
       (>!! read-ch (if (instance? ByteBuf in) (buffer->bytes in)  in))
-      (info "Read0 Done " (Thread/currentThread))
+      ;(info "Read0 Done " (Thread/currentThread))
       
       )
     (exceptionCaught [^ChannelHandlerContext ctx cause]

     (thread
	      (loop [local-client client]
	          (let [ write-ch (:write-ch local-client)
	                 v (<! write-ch)]
	               (cond  (instance? Stop v) nil
                        (instance? Reconnected v) (do
	                                                        (error ">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>  Writer received reconnected " (:client v))

  (reify GenericFutureListener
    (operationComplete [this f]
       ;(go (>! write-lock-ch 1))
       (thread 
               (try
                  (close-client client)
                  (catch Exception e (do
                                       (error (str "Close listener error " e)  e)
                                       (>!! internal-error-ch [e nil])
                                       )))))))
           

