 
 (defn generate-event [root-url url body]
   {:timestamp (System/currentTimeMillis)
-   :sourceId root-url
+   :sourceId url
    :rootUrl root-url
    :eventName "web-crawl"
    :url url


(defrecord WebSource [^String root-url
                      ^Integer  url-limit
                      crawler
                      running]


      (println print-friendly)))

  (with-redefs [data-to-flows dtf]
    (let [service (WebSource. "http://www.google.com" 50 true (atom nil) (atom nil))]
      (.start service)
      (Thread/sleep 30000) ;stay within this context (so that dtf function is used)
      (.stop service)))
