     :onyx/bootstrap? true
     :datomic/uri db-uri
     :datomic/t t
-    :onyx/batch-size 1000
+    :onyx/batch-size batch-size
     :datomic/partition :com.mdrogalis/people
     :onyx/doc "Creates ranges over an :eavt index to parellelize loading datoms"}
 

    :hornetq/queue-name out-queue
    :hornetq/host hornetq-host
    :hornetq/port hornetq-port
    :onyx/batch-size 1000
    :onyx/doc "Output source for intermediate query results"}])

(def conn (onyx.api/connect (str "onyx:memory//localhost/" id) coord-opts))


(def t (d/next-t db))

(def batch-size 1000)

(def hornetq-host "localhost")

(def hornetq-port 5445)
