                :subscription subscription
                :connection-redundancy connection-redundancy)
 
-  (let [self-id (get-in node [:self :id])]
+  (let [self-id (networked-node->node-contact-address node)]
     (when (= self-id subscription)
       (throw (ex-info (str "Got own new subscription: " subscription) {:node node})))
 


(s/defn node->removed :- NetworkedNodeSchema
  [node :- NetworkedNodeSchema]
  (-> (get-in node [:self :id])
      node-contact-address->node
      (assoc :removed? true)))


               :receive-msg-forwarded-subscription
               :node node
               :subscriber-contact-address subscriber-contact-address)
  (let [self-id (networked-node->node-contact-address node)]
    (if (and (not= self-id subscriber-contact-address)
             (not (downstream subscriber-contact-address))
             ;; The subscription id is not for this node itself, and
