 
 (def sample-node
   {:self {:id "node-id5"
-          :host "127.0.0.1"
-          :port 2005}
-
-   :partial-view :downstream
-   :local-view :downstream
+          ;; :host "127.0.0.1"
+          ;; :port 2005
+          }
+
+   ;; :partial-view :downstream
+   ;; :local-view :downstream
    :downstream #{"node-id1" ; node-contact-address for node-id1
                  "node-id2" ; node-contact-address for node-id2
                  }
 
-   :in-view :upstream
+   ;; :in-view :upstream
    :upstream #{"node-id3" ; node-contact-address for node-id3
                "node-id4" ; node-contact-address for node-id4
-               }})
+               }
+   :messages-seen {}})
 
 (def sample-subscription-request
   {:new-node-contact-address "node-id6"

               :message-type message-type
               :message-body message-body
               :envelope-id envelope-id)
  (let [destination-node (update-in destination-node [:messages-seen envelope-id] #(if % (inc %) 1))]
    (if (< (get-in destination-node [:messages-seen envelope-id])
           message-dup-drop-after)
      (condp = message-type

                                                               destination-node
                                                               message-body
                                                               envelope-id)
        (timbre/log* logging :error
                     :read-mail-unknown-message-type
                     :destination-node destination-node
                     :message-type message-type
                     :message-body message-body))
      (do
        (timbre/log* logging :trace
                     :read-mail-dropping-dup
