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




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

                    (interrupt pe))
                  (.interrupt out-proc-loop))
     :in-fn (fn [in]
              (enqueue in-queue (LocalTransferContainer. in nil)))}))

(defn get-in-fn
  [obj]
