                 (catch Exception e
                   (taoensso.timbre/error e)
                   (throw e)))
-              (recur)))))
+              (recur))))))
 
 (defrecord NettyTcpSockets [peer-group]
   component/Lifecycle

                        set)
        port (first (remove used-ports
                            (:netty/ports peer-site)))]
    (assert port)
    {:netty/port port}))

(defn int32-frame-decoder

(ns ^:no-doc onyx.messaging.netty-tcp
    (:require [clojure.core.async :refer [chan >!! >! <!! alts!! timeout close! thread go-loop dropping-buffer]]
              [com.stuartsierra.component :as component]
              [taoensso.timbre :as timbre]
              [onyx.messaging.protocol-netty :as protocol]
