           decompress-f (or (:onyx.messaging/decompress-fn opts) decompress)
           virtual-peers (atom (pm/vpeer-manager))
           publications (atom {})
-          connections (atom {})
           subscriber-count (arg-or-default :onyx.messaging.aeron/subscriber-count opts)
           subscribers (mapv (fn [stream-id]
                               (start-subscriber! bind-addr port stream-id virtual-peers decompress-f receive-idle-strategy))
                             (range subscriber-count))
-          pub-gc-thread (future (gc-publications publications connections opts))]
+          pub-gc-thread (future (gc-publications publications opts))]
       (assoc component
              :pub-gc-thread pub-gc-thread
              :bind-addr bind-addr

          (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")

             :subscriber-count subscriber-count
             :subscribers subscribers)))

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