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

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

											                            (error "!!!!! Error while writing " e)  
											                            (thread (>!! internal-error-ch [e 1]))
			                                    )))
                             (recur local-client))
	                      )))
                 
                  )
