                     :pubsub   pubsub
                     :services [s1 s2]
                     :streams  [index]})
-         client   (client/tcp-client)
+         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:5558/index?query=true"})]
+                      :url    "http://127.0.0.1:15558/index?query=true"})]
      (try
        (client/send-event client {:service "service1"})
        (client/send-event client {:service "service2"})


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

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