 
 (defn read-until-delimiter [socket]
   (let [preamble (doall (drop-last
-                         (take-while (comp not #(= "<IDS|MSG>" (try-convert-to-string %)))
+                         (take-while (comp not #(= "<IDS|MSG>"
+                                                   (try-convert-to-string %)))
                                      (repeatedly #(zmq/receive socket)))))]
     preamble))
 

            (println "Message dump:" message)
            (System/exit -1)))))))


(defrecord Heartbeat [addr]
    Runnable
    (run [this]

                                  :status "ok"
                                  :started (now)} session-id signer (:idents message)))
          )
        (send-message iopub-socket "status" (status-content "idle")
                      parent-header {} session-id signer)))))

