              :subscriber-count subscriber-count
              :subscribers subscribers)))
 
-  (stop [{:keys [media-driver media-driver-context subscribers publications connections] :as component}]
+  (stop [{:keys [media-driver media-driver-context subscribers publications] :as component}]
     (taoensso.timbre/info "Stopping Aeron Peer Group")
     (future-cancel (:pub-gc-thread component))
     (doseq [subscriber subscribers]

          (fatal e)))
      (recur))))

(defrecord AeronPeerGroup [opts publications connections subscribers subscriber-count compress-f decompress-f send-idle-strategy]
  component/Lifecycle
  (start [component]
    (taoensso.timbre/info "Starting Aeron Peer Group")

                             (filter (fn [[k v]] (>= (- t ^long @(:last-used v)) idle))
                                     snapshot))]
          (doseq [k to-remove]
            (let [pub-manager (:publication (snapshot k))
                  pub (:publication pub-manager)
                  conn (:connection pub-manager)]
              (swap! publications dissoc k)
              (.close ^Publication pub)
              (.close ^Aeron conn))))
        (catch InterruptedException e
