                        (log/info "Storing " (count snapshot) " samples.")
                        (data/with-db-connection db-pool
                          (data/store-data-samples (seq snapshot)))))
-                  "Store inbound queue")
+                  "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 []


(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

               :type "text/javascript"}]]]))

(defn all-routes [ store-samples ]
  (routes
   (GET "/series-names" []
     (transit-response
