     (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))
-

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

            [photon.config :as conf]
            [photon.filedb :as filedb]
            [photon.db :as db]
            [photon.muon :as muon]
            [photon.current.common :refer :all])
  (:use midje.sweet))

(defn elem-count [ch]
