 
 (hq-utils/write-and-cap! hq-config in-queue people 1)
 
-(def id (str (java.util.UUID/randomUUID)))
-
-(def coord-opts {: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
-                 :onyx.coordinator/revoke-delay 5000})
-
-(def peer-opts
-  {:hornetq/mode :vm
-   :zookeeper/address "127.0.0.1:2185"
-   :onyx/id id})
-
-(def workflow {:input {:to-datom :output}})
+(def workflow {:in {:to-datom :out}})
 
 (def catalog
-  [{:onyx/name :input
+  [{:onyx/name :in
     :onyx/ident :hornetq/read-segments
     :onyx/type :input
     :onyx/medium :hornetq

  {: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)))

