 
 (def t (d/next-t db))
 
+(def batch-size 1000)
+
 (def hornetq-host "localhost")
 
 (def hornetq-port 5445)

    :onyx/fn :onyx.plugin.input-test/my-test-query
    :onyx/type :transformer
    :onyx/consumption :concurrent
    :onyx/batch-size 1000
    :onyx/doc "Queries for names of 5 characters or fewer"}

   {:onyx/name :persist

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

