 (defn create-local-processing-pipeline
   [fns out-fn]
   (let [running (atom true)
-        in-queue (LinkedTransferQueue.)
+        in-queue (create-queue)
         proc-elements (reduce
                         (fn [v f]
                           (conj v (create-local-processing-element (get-out-queue (last v)) f)))




(defn create-local-processing-element
  [^BlockingQueue in-queue f]
  (let [running (atom true)
        out-queue (LinkedTransferQueue.)
        proc-loop (ProcessingLoop.
                    (fn []
                      (try

  (:require [dsbdp.data-processing-dsl :refer :all])
  (:import
    (dsbdp LocalTransferContainer ProcessingLoop)
    (java.util.concurrent ArrayBlockingQueue BlockingQueue LinkedTransferQueue TransferQueue)))



