 (ns brainbot.nozzle.esconnect
   (:require [clojure.tools.logging :as logging])
-  (:require [brainbot.nozzle.misc :as misc])
-  (:require [clojurewerkz.elastisch.rest :as esr]
+  (:require [langohr.core :as rmq]
+            [langohr.consumers :as lcons]
+            [langohr.basic :as lb])
+  (:require [brainbot.nozzle.misc :as misc]
+            [brainbot.nozzle.mqhelper :as mqhelper])
+  (:require [clojurewerkz.elastisch.rest.document :as esd]
+            [clojurewerkz.elastisch.rest :as esr]
             [clojurewerkz.elastisch.rest.index :as esi]))
 
 ;; (esr/connect! "http://127.0.0.1:9200")

    (esi/create index-name :mappings mapping-types)))



(defn esconnect-run-section
  [iniconfig section]

     (logging/info "connecting to elasticsearch" es-url)
    (esr/connect! es-url)
    (ensure-index-and-mappings es-index)
    (mqhelper/connect-loop
     #(rmq/connect rmq-settings)
     (build-handle-connection es-index filesystems))))
