              :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]

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


;; FIXME: gc'ing publications could be racy if a publication is grabbed
;; just as it is being gc'd - though it is unlikely
(defn gc-publications [publications opts]
  (let [interval (arg-or-default :onyx.messaging/peer-link-gc-interval opts)
        idle (arg-or-default :onyx.messaging/peer-link-idle-timeout opts)]
    (loop []
