     :onyx/batch-timeout batch-timeout
     :onyx/batch-size batch-size}
 
-   {:onyx/name :inc
+   {:onyx/name :inc1
+    :onyx/fn :onyx.plugin.bench-plugin-test/my-inc
+    :onyx/type :function
+    :onyx/batch-timeout batch-timeout
+    :onyx/batch-size batch-size}
+
+   {:onyx/name :inc2
+    :onyx/fn :onyx.plugin.bench-plugin-test/my-inc
+    :onyx/type :function
+    :onyx/batch-timeout batch-timeout
+    :onyx/batch-size batch-size}
+
+   {:onyx/name :inc3
+    :onyx/fn :onyx.plugin.bench-plugin-test/my-inc
+    :onyx/type :function
+    :onyx/batch-timeout batch-timeout
+    :onyx/batch-size batch-size}
+
+   {:onyx/name :inc4
     :onyx/fn :onyx.plugin.bench-plugin-test/my-inc
     :onyx/type :function
     :onyx/batch-timeout batch-timeout

   :onyx/id id
   :onyx.messaging/bind-addr "127.0.0.1"
   :onyx.messaging/peer-ports (vec (range 40000 40200))
   ;:onyx.peer/join-failure-back-off 500
   :onyx.peer/job-scheduler scheduler
   :onyx.messaging/impl messaging})

(def peer-group 
  (onyx.api/start-peer-group peer-config))

(def batch-size 1)
(def batch-timeout 100)

(def counter (atom 0))

(defn my-inc [{:keys [n] :as segment}]
  (swap! counter inc)
  (assoc segment :n (inc n)))

(def catalog


(future
  (while true 
    (println "Retry counter " @retry-counter)
    (println "Update " @counter (float (/ @counter
                                          (/ (- (System/currentTimeMillis) start-time-millis) 
                                             1000))) "/sec")
