       (when delayer
         (future-cancel delayer)
         (when flusher
-          (deref flusher))))))
+          (deref flusher)))))
+  (debug "The cache has been flushed"))
 
 (defn store-chan
   [chan tenant period rollup time path data ttl]

              adata (get-data @pkeys)]
          (swap! adata #(assoc % ckey (conj (get % ckey) data)))))
      (flush! [this]
        (debug "Flushing the cache...")
        (run-flusher! mkeys)
        (debug "The cache has been flushed"))
      (-show-keys [this] (debug "MKeys:" mkeys))
      (-show-cache [this]
        (debug "Cache:")


(defn run-flusher!
  [mkeys]
  (debug "Flushing the cache...")
  (doseq [[mkey pkeys] @mkeys]
    (let [m (meta @pkeys)
          delayer (get m :delayer nil)
