 
 (defrecord AeronPeerConnection [channel id])
 
-;;;; THIS CAN BE MADE FASTER BY NOT GOING THROUGH PEER-LINK IN OPERATION
 (defmethod extensions/connect-to-peer AeronConnection
   [messenger peer-id event {:keys [aeron/external-addr aeron/port aeron/id]}]
   (->AeronPeerConnection (aeron-channel external-addr port) id))

          retry-ch (chan (sliding-buffer (arg-or-default :onyx.messaging/retry-ch-buffer-size config)))
          acking-ch (:acking-ch (:acking-daemon component))
          send-idle-strategy (:send-idle-strategy messaging-group)
          compress-f (:compress-f (:messaging-group peer-group))]
      (assoc component 
             :messaging-group messaging-group
             :short-circuitable? short-circuitable?
             :publications publications
             :connections connections
             :virtual-peers virtual-peers
             :send-idle-strategy send-idle-strategy
             :compress-f compress-f

           :publications nil
           :connections nil
           :virtual-peers nil
           :multiplex-id nil
           :compress-f nil :decompress-f nil 
           :inbound-ch nil :release-ch nil :retry-ch nil )))

(defrecord PeerChannels [acking-ch inbound-ch release-ch retry-ch])

(defmethod extensions/open-peer-site AeronConnection
  [{:keys [virtual-peers multiplex-id acking-ch inbound-ch release-ch retry-ch] :as messenger} 
   {:keys [aeron/id]}]
  (reset! multiplex-id id)
  (swap! virtual-peers assoc id (->PeerChannels acking-ch inbound-ch release-ch retry-ch))) 

(def no-op-error-handler
  (reify ErrorHandler 
