           (fatal e)))
       (recur))))
 
-(defrecord AeronPeerGroup [opts publications connections subscribers subscriber-count compress-f decompress-f send-idle-strategy]
+(defrecord AeronPeerGroup [opts publications 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 (:publication (snapshot k))
                  conn (@connections k)]
              (swap! publications dissoc k)
              (swap! connections dissoc k)
              (.close ^Publication pub)
              (.close ^Aeron conn))))
        (catch InterruptedException e

          decompress-f (or (:onyx.messaging/decompress-fn opts) decompress)
          virtual-peers (atom (pm/vpeer-manager))
          publications (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 opts))]
      (assoc component
             :pub-gc-thread pub-gc-thread
             :bind-addr bind-addr
