     :hornetq/queue-name in-queue
     :hornetq/host hornetq-host
     :hornetq/port hornetq-port
-    :hornetq/batch-size 2}
+    :onyx/batch-size 2}
 
    {:onyx/name :to-datom
     :onyx/fn :onyx.plugin.output-test/to-datom
-    :onyx/type :transformer
+    :onyx/type :function
     :onyx/consumption :concurrent
     :onyx/batch-size 2}
    
-   {:onyx/name :output
+   {:onyx/name :out
     :onyx/ident :datomic/commit-tx
     :onyx/type :output
     :onyx/medium :datomic

  {:datoms [{:db/id (d/tempid :com.mdrogalis/people)
             :user/name name}]})

(def conn (onyx.api/connect :memory coord-opts))

(def v-peers (onyx.api/start-peers conn 1 peer-opts))

(onyx.api/submit-job conn {:catalog catalog :workflow workflow})

(doseq [_ (range (count people))]
  (.take tx-queue))

(ns onyx.plugin.output-test
  (:require [midje.sweet :refer :all]
            [com.stuartsierra.component :as component]
            [datomic.api :as d]
            [onyx.plugin.datomic]
            [onyx.queue.hornetq-utils :as hq-utils]
            [onyx.system :refer [onyx-development-env]]
            [onyx.api]))

(def id (java.util.UUID/randomUUID))

(def env-config
  {:hornetq/mode :vm
   :hornetq/server? true
   :hornetq.server/type :vm
   :zookeeper/address "127.0.0.1:2185"
   :zookeeper/server? true
   :zookeeper.server/port 2185
   :onyx/id id})

(def peer-config
  {:hornetq/mode :vm
   :zookeeper/address "127.0.0.1:2185"
   :onyx/id id
   :onyx.peer/inbox-capacity 100
   :onyx.peer/outbox-capacity 100
   :onyx.peer/job-scheduler :onyx.job-scheduler/round-robin})

(def dev (onyx-development-env env-config))

(def env (component/start dev))

(def db-uri (str "datomic:mem://" (java.util.UUID/randomUUID)))

