 (ns brainbot.nozzle.esconnect
+  (:require [clojure.string :as string])
   (:require [clojure.tools.logging :as logging])
   (:require [langohr.core :as rmq]
             [langohr.consumers :as lcons]



(defn simple-update_directory
  [fs {:keys [directory entries] :as body} {publish :publish}]
  (println "update-directory" body))


(defn build-handle-connection

(defn es-listdir
  [index-name parent]
  (esd/search index-name
              ["dir" "doc"]
              :size 1000000
              :query {:match_all {}}
              :filter {:term {:parent parent}}))
