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

           ["riemann.transport"
            "riemann.core"
            "riemann.pubsub"]
           (let [server (ws-server)
                 uri    "http://127.0.0.1:5556/events"
                 core   (transition! (core) {:services [server]})]
             ; Two simple events
             (let [res (http/put uri

                    :pubsub   pubsub
                    :services [s1 s2]
                    :streams  [index]})
         client   (client/tcp-client {:port 15555})
         convert  (comp json/parse-string
                        second
                        (partial re-matches #"data: (.*)\n\n")
                        formats/bytes->string)
         response @(http-request
                     {:method :get
                      :url    "http://127.0.0.1:15558/index?query=true"})]
     (try
       (client/send-event client {:service "service1"})
       (client/send-event client {:service "service2"})
