                        (encode {:ok true}))]
 
              (try
-               (enqueue client {:host "localhost" 
-                                :port 5555 
+               (enqueue client {:host "localhost"
+                                :port 5555
                                 :message msg})
                (Thread/sleep 100)
                (finally

                        second
                        (partial re-matches #"data: (.*)\n\n")
                        formats/bytes->string)
         response (http-request 
                   {:method :get
                    :url    "http://127.0.0.1:5558/index?query=true"})]
     (try
       (client/send-event client {:service "service1"})
       (client/send-event client {:service "service2"})
       (Thread/sleep 100)
       (let [[r2 r1] (channel->seq (map* convert (take* 2 (:body @response))))]

         (is (#{"service1" "service2"} (get r1 "service")))

         s2       (sse-server)
         index    (index/index)
         pubsub   (pubsub/pubsub-registry)
         core     (transition!
                   (core)
                   {:index    index
                    :pubsub   pubsub
