   (fact "One event on stream" (elem-count ch) => 1)
   (dorun (take 10 (repeatedly
                    (fn []
-                     (post-one-event
+                      (post-one-event
                       m (str "photon-integration-test-" uuid))))))
   (let [ch (cl/with-muon m
              (cl/stream-subscription (str "muon://photon-integration-test-"

    (Thread/sleep 20000)
    (fact "11011 events on stream" (elem-count ch) => 11011)))



#_(let [m (cl/muon-client amazon-url "client-test" "client" "test")]
  (Thread/sleep 5000)
  (let [res (cl/with-muon m
              #_(cl/query-event "muon://photon/projection" {:projection-name "test"})
              (dorun (take 10 (repeatedly (fn [] (cl/post-event "muon://photon/events" "chatter"
                                                        {"service-id","muon://chatter","local-id","6198cea7-b260-4bb7-963d-f102132032fe","payload",{"id","dbd6eecf-8f5c-42aa-8aa8-1b2172d53c71","text","substitutable","textanalysis",{"aggregateSentiment",40,"keyphrases",[{"phrase","substitutable","count",1}]}},"stream-name","dummy","server-timestamp",1420660080000}))))))]
    (log/info res)
    res))


      n
      (recur (<!! ch) (inc n)))))

(let [uuid (java.util.UUID/randomUUID)
      ms (new-server uuid)
      m (cl/muon-client (:amqp.url conf/config) "client-test"
                        "client" "test")
      res (post-one-event m (str "photon-integration-test-" uuid))
      ch (cl/with-muon m
           (cl/stream-subscription (str "muon://photon-integration-test-"
                                        uuid "/stream")
