                :type "text/javascript"}]]]))
 
 (defn all-routes [ store-samples ]
-  (log/info "data sink" store-samples )
   (routes
    (GET "/series-names" []
      (transit-response


(def my-pool (at-at/mk-pool))

(defn queued-data-sink [ db-pool ]
  (let [ sample-queue (java.util.concurrent.LinkedBlockingQueue.) ]
    (at-at/every 30
                 (exception-barrier
                  #(let [ snapshot (java.util.concurrent.LinkedBlockingQueue.) ]
                     (locking sample-queue

                       (log/info "Storing " (count snapshot) " samples.")
                       (data/with-db-connection db-pool
                         (data/store-data-samples (seq snapshot)))))
                  "Store ingress queue contents")
                 my-pool)
    (fn [ samples ]
      (log/info "Enqueuing " (count samples) " samples for later storage.")
      (doseq [ sample samples ]
        (log/info "sample" sample)
        (.add sample-queue sample)))))

(defmacro get-version []
