           (extensions/checkpoint sync :revoke-log offset))
         (recur)))))
 
-(defn exhaust-queue-loop [sync sync-ch exhaust-tail seal-head]
+(defn exhaust-queue-loop [sync sync-ch exhaust-tail seal-head dead-ch]
   (loop []
     (when-let [node (:path (<!! exhaust-tail))]
       (when-let [result (exhaust-queue sync sync-ch node)]


      (dire/with-handler! #'shutdown-ch-loop
        java.lang.Exception (fn [e & _] (warn e)))

      (r/repair-planning-messages! sync #(>!! planning-ch-head %))
      (r/repair-birth-messages! sync #(>!! born-peer-ch-head %))


(defn offer-ch-loop
  [sync sync-ch revoke-delay offer-tail ack-head exhaust-head
   complete-head revoke-head dead-ch]
  (loop []
    (when (<!! offer-tail)
      (let [offset (extensions/next-offset sync :offer-log)]
