         (.channel ^ChannelFuture (.connect b host port))))))
 
 (defn app [daemon messenger buf-recv-ch inbound-ch release-ch retry-ch shutdown-ch]
-  (go-loop []
+  (thread
+    (loop []
           (let [[buf ch] (alts!! [buf-recv-ch shutdown-ch])]
             (when buf 
               (try 
                 (let [msg (protocol/read-buf (:decompress-f messenger) buf)]
+                  ;(taoensso.timbre/info "Message buf: " buf msg)
                   ;; undo retain added in server handler
                   (.release ^ByteBuf buf)
                   (let [t ^byte (:type msg)]

    (taoensso.timbre/info "Stopping Netty TCP Sockets")
    (try 
      (when-let [rs @resources]
        (let [{:keys [shutdown-fn shutdown-ch]} rs] 
          (close! shutdown-ch)
          (shutdown-fn))
        (reset! resources nil)) 
      (catch Exception e (timbre/fatal e)))
    (assoc component :bind-addr nil :external-addr nil 

      (.childOption ChannelOption/TCP_NODELAY true)
      (.childOption ChannelOption/SO_KEEPALIVE true)
      (.childHandler initializer))
    (let [ch (->> (InetSocketAddress. host port)
                  (.bind bootstrap)
                  (.sync)
