autolink2.clj

(defn m-dec [buf]
  (io/decode utf-codec buf))

(defn channel-handler [ch]
  (go-loop []
    (let [ch-data (<! ch) ]
      (try
        (let [msg (m-dec ch-data)]
          (println "->" msg)
          (if (= msg "stop")
            (throw (Exception. "my exception message"))))
        (catch Exception e (prn "channel exception: " (.getMessage e))
                           (close! ch)
                           (prn "channel shutdown!")))
      (if-not (= ch-data nil)
        (recur)))))

(defn channel-new []
  (let [ch (chan)]
    (channel-handler ch) ch))