This commit is contained in:
Bryce Covert
2020-04-27 09:30:30 -07:00
parent b89b4a86c5
commit 25f1cebe51
9 changed files with 196 additions and 127 deletions

View File

@@ -116,7 +116,7 @@
(defn process-one [report-queue]
(let [transaction (.take report-queue)
_ (println "processing transaction" transaction)
_ (println "processing transaction")
db (:db-after transaction)
affected-entities (->> (:tx-data transaction)
(map (fn [^datomic.db.Datum x]
@@ -144,6 +144,7 @@
(def break (atom false))
(defn process-all []
(println "Starting worker")
(while (and (not @break)
(not (Thread/interrupted)))
(process-one (d/tx-report-queue (d/connect uri) ))))