    ["riemann.transport" "riemann.core" "riemann.pubsub"]
    (let [s1       (tcp-server)
          s2       (sse-server)
-         index    (wrap-index (index/index))
+         core     (core)
+         index    (wrap-index (index/index) (:pubsub core))
          pubsub   (pubsub/pubsub-registry)
          core     (transition!
-                   (core)
+                   core
                    {:index    index
                     :pubsub   pubsub
                     :services [s1 s2]

                        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")))
         (is (#{"service1" "service2"} (get r2 "service"))))
       (finally

            [riemann.index :as index])
  (:import (org.jboss.netty.buffer ChannelBuffers)
           (java.io IOException)))

(deftest ws-put-events-test
         (riemann.logging/suppress
