     (reap/start-watching-futures!)
 
     (doseq [filesystem filesystems]
-      (reap/register-future! (future (handle-command-for-filesystem filesystem))
+      (reap/register-future! (future (handle-command-for-filesystem filesystem options))
                              die-on-exit-or-error die-on-exit-or-error)))
 
 

    queue-name))

(defn run-with-connection
  [filesystem]
  (let [conn       (rmq/connect)
        ch         (lch/open conn)
        queue-name (initialize-rabbitmq-structures ch "extract_content" "nextbot" filesystem)]

    ;; (lq/declare ch queue-name :exclusive false :auto-delete true)
    ;; (lq/bind    ch queue-name "nextbot")



(defn handle-command-for-filesystem
  [filesystem options]
  (while true
    (try
      (run-with-connection filesystem options)
      (catch Exception err
        (logging/error "got exception" err)
        (trace/print-stack-trace err)
