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

                                    "riemann.pubsub"]
            (let [server (tcp-server)
                  core   (transition! (core) {:services [server]})
                  client (wait-for-result 
                           (aleph.tcp/tcp-client 
                             {:host "localhost" 
                              :port 5555
                              :frame (finite-block :int32)}))]

              (try
                (enqueue client 
                         (java.nio.ByteBuffer/wrap 
                           (byte-array (map byte [0 1 2]))))
                (is (thrown? java.lang.IllegalStateException
                             (wait-for-message client)))

                        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 500)
       (let [[r2 r1] (channel->seq (map* convert (take* 2 (:body @response))))]

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