 
            (.await ^ChannelFuture (.disconnect channel))
            (.await ^ChannelFuture (.close channel))
-           ))
+           (close! write-ch)
+           (close! internal-error-ch)))
 
 
 (defn close-all [{:keys [group closed] :as conf}]

		              (do 
                           (write-poison local-client)
			               (.set ^AtomicBoolean (:closed local-client) true)
			               (>!! error-ch [v o]) ;send the error channel)
                (catch Exception e (error e e))))
             (do
		          (if (instance? Poison v)

	                      )))))
	    
    
		    client))


       
