     :onyx/fn :onyx.plugin.datomic/load-datoms
     :onyx/type :transformer
     :onyx/consumption :concurrent
-    :onyx/batch-size 1000
+    :onyx/batch-size batch-size
     :datomic/uri db-uri
     :datomic/t t
     :onyx/doc "Reads and enqueues a range of the :eavt datom index"}

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



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

(def batch-size 1000)

(def hornetq-host "localhost")

(def hornetq-port 5445)
