          (let [qname (misc/initialize-rabbitmq-structures ch "update_directory" "nextbot" fs)]
            (logging/info "starting consumer for" qname)
            (lb/qos ch 1)
-           (lcons/subscribe ch qname (mqhelper/make-handler (partial simple-update_directory fs)))))))))
+           (lcons/subscribe ch qname
+                            (mqhelper/make-handler (partial simple-update_directory fs es-index)))))))))
 
 
 (defn esconnect-run-section



(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}}))
