     ;;                  (fn [consumer_tag reason]
     ;;                    (println "shutdown" consumer_tag reason))
 
+    ;; (break-channel ch 2000)
     (lcons/blocking-subscribe ch queue-name handle-message :auto-ack false)))
 
 

                     (println "hello")
                     (println "headers" headers)
                     ;; (println (format "[consumer] Received %s" (String. payload "UTF-8")))
                     (lb/ack ch delivery-tag))]
    ;; (lq/declare ch queue-name :exclusive false :auto-delete true)
    ;; (lq/bind    ch queue-name "nextbot")
    (lb/qos ch (+ number-of-cores 4))

        ;; converted (tika/parse fp)
        ]
        ;;
    (future (
             (println "starting...")
             (let [converted (convert fp)]
              (println "before ack" (Thread/currentThread) (:delivery-tag metadata))
              (lb/ack ch (:delivery-tag metadata))
              (println "done" fp " ****" ))))

    (println "scheduled" fp " ****" )))

