             [langohr.queue :as lq]
             [langohr.channel :as lch]
             [langohr.consumers :as lcons])
-  ;; (:require [me.raynes.fs :as fs])
-  (:require [clojure.tools.cli :as cli])
-  (:require [clojure.string :as string])
-  (:require [brainbot.nozzle.stat :as stat]
-            [brainbot.nozzle.vfs :as vfs])
-  (:require [clojure.stacktrace :as trace])
-  (:require [com.brainbot.iniconfig :as ini])
-  (:require [tika])
-  (:import java.io.File)
-  (:import [com.rabbitmq.client Address ConnectionFactory Connection Channel ShutdownListener])
-  (:import [java.util.concurrent Executors]))
+  (:require [brainbot.nozzle.vfs :as vfs]))
 
 
 (defn get-permissions-for-entry

  [fs directory entries]
  (map (partial get-permissions-for-entry fs directory)
       entries))

(defn entry-is-type?
  [type entry]

(ns brainbot.nozzle.fsworker
  (:require [clojure.tools.logging :as logging])
  (:require [brainbot.nozzle.mqhelper :as mqhelper]
            [brainbot.nozzle.misc :as misc])
  (:require [langohr.basic :as lb]
            [langohr.shutdown :as lshutdown]
