diff options
| author | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-23 11:06:33 +0200 |
|---|---|---|
| committer | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-23 11:06:33 +0200 |
| commit | 60f7371f4d2dd43c5b177039406eeaab00ba27cc (patch) | |
| tree | 9e34ea2576650b83e41c05f5fd3fc48c7ebf0865 /test/com/github/ivarref/yoltq/test_utils.clj | |
| parent | Add consume-twice! test function for verifying idempotence (diff) | |
| download | fiinha-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.clj | 16 |
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)) |
