diff --git a/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj b/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
index 3f29a0ab..1da1088c 100644
--- a/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
+++ b/src/clj/auto_ap/datomic/migrate/add_general_ledger.clj
@@ -70,7 +70,7 @@
 
 #_(bulk-load-invoice-ledger (d/connect auto-ap.datomic/uri))
 (def make-entity-not-unique
-  [[[:db/retract :general-ledger/original-entity :db/unique]]])
+  [[[:db/retract :general-ledger/original-entity :db/unique :db.unique/identity]]])
 
 
 
diff --git a/src/clj/auto_ap/ledger.clj b/src/clj/auto_ap/ledger.clj
index d72157b9..4136fd62 100644
--- a/src/clj/auto_ap/ledger.clj
+++ b/src/clj/auto_ap/ledger.clj
@@ -2,7 +2,6 @@
   (:require [datomic.api :as d]
             [auto-ap.datomic :refer [uri remove-nils]]))
 
-(defonce report-queue (d/tx-report-queue (d/connect uri) ) )
 
 (defn datums->impacted-entity [db [e changes]]
   (let [entity (d/pull db '[* {:invoice/_expense-accounts [*]}] e)
@@ -65,7 +64,7 @@
   (into [[:replace-general-ledger (:general-ledger/original-entity (first entries))]]
         entries))
 
-(defn process-one []
+(defn process-one [report-queue]
   (let [transaction (.take report-queue)
         db (:db-after transaction)
         affected-entities (->> (:tx-data transaction)
@@ -90,7 +89,7 @@
 
 (defn process-all []
   (while (not (Thread/interrupted))
-    (process-one)))
+    (process-one (d/tx-report-queue (d/connect uri) ))))