aboutsummaryrefslogtreecommitdiff
path: root/test/com/github/ivarref/yoltq/test_utils.clj
diff options
context:
space:
mode:
authorIvar Refsdal <ivar.refsdal@nsd.no>2021-09-23 11:06:33 +0200
committerIvar Refsdal <ivar.refsdal@nsd.no>2021-09-23 11:06:33 +0200
commit60f7371f4d2dd43c5b177039406eeaab00ba27cc (patch)
tree9e34ea2576650b83e41c05f5fd3fc48c7ebf0865 /test/com/github/ivarref/yoltq/test_utils.clj
parentAdd consume-twice! test function for verifying idempotence (diff)
downloadfiinha-60f7371f4d2dd43c5b177039406eeaab00ba27cc.tar.gz
fiinha-60f7371f4d2dd43c5b177039406eeaab00ba27cc.tar.xz
To test-queue namespace
Diffstat (limited to 'test/com/github/ivarref/yoltq/test_utils.clj')
-rw-r--r--test/com/github/ivarref/yoltq/test_utils.clj16
1 files changed, 8 insertions, 8 deletions
diff --git a/test/com/github/ivarref/yoltq/test_utils.clj b/test/com/github/ivarref/yoltq/test_utils.clj
index dacba68..df56460 100644
--- a/test/com/github/ivarref/yoltq/test_utils.clj
+++ b/test/com/github/ivarref/yoltq/test_utils.clj
@@ -2,7 +2,7 @@
(:require [com.github.ivarref.yoltq.log-init :as logconfig]
[clojure.tools.logging :as log]
[com.github.ivarref.yoltq.utils :as u]
- [com.github.ivarref.yoltq :as dq]
+ [com.github.ivarref.yoltq :as yq]
[datomic.api :as d]
[clojure.string :as str]
[com.github.ivarref.yoltq.impl :as i]
@@ -35,7 +35,7 @@
(defn put-transact! [id payload]
- @(d/transact (:conn @dq/*config*) [(i/put @dq/*config* id payload)]))
+ @(d/transact (:conn @yq/*config*) [(i/put @yq/*config* id payload)]))
(defn advance! [tp]
@@ -50,25 +50,25 @@
:where
[?e :com.github.ivarref.yoltq/id _]
[?e :com.github.ivarref.yoltq/status :done]]
- (d/db (:conn @dq/*config*))))
+ (d/db (:conn @yq/*config*))))
(defn get-init [& args]
- (apply u/get-init @dq/*config* args))
+ (apply u/get-init @yq/*config* args))
(defn get-error [& args]
- (apply u/get-error @dq/*config* args))
+ (apply u/get-error @yq/*config* args))
(defn get-hung [& args]
- (apply u/get-hung @dq/*config* args))
+ (apply u/get-hung @yq/*config* args))
(defn take! [& args]
- (apply i/take! @dq/*config* args))
+ (apply i/take! @yq/*config* args))
(defn execute! [& args]
- (apply i/execute! @dq/*config* args))
+ (apply i/execute! @yq/*config* args))