                                            fn-mapping
                                            sample-pcap-processing-definition-json))
                        out-fn))
+          batch-delay (:batch-delay options)
+          batch-size (:batch-size options)
           in-loop (ProcessingLoop.
                     "DataGenerationLoop"
                     (cond

    :parse-fn #(binding [*read-eval* false] (read-string %))]
   ["-s" "--scenario SCENARIO"
    "The scenario that is to be used."
    :default "no-op"]])

(defn -main [& args]
  (println "Starting dsbdp main...")

                          (fn []
                            (proc-fn in-data)
                            (.inc out-cntr)))
                      (and
                        in-data
                        (> batch-delay 0)
                        (> batch-size 0)) (let [in-fn (get-in-fn pipeline)]
                                           (fn []
                                             (doseq [i (repeat batch-size 0)]
                                               (in-fn in-data)
                                               (.inc in-cntr)))
                                             (sleep batch-delay))
                      in-data (let [in-fn (get-in-fn pipeline)]
                                (fn []
                                  (in-fn in-data)
                                  (.inc in-cntr)))
                      :default (fn [] (.inc out-cntr))))
          thread-info-fn (create-thread-info-fn)
          stats-fn (fn []
