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 /src | |
| 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 'src')
| -rw-r--r-- | src/com/github/ivarref/yoltq/test_queue.clj (renamed from src/com/github/ivarref/yoltq/virtual_queue.clj) | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/com/github/ivarref/yoltq/virtual_queue.clj b/src/com/github/ivarref/yoltq/test_queue.clj index db429a8..6aeb959 100644 --- a/src/com/github/ivarref/yoltq/virtual_queue.clj +++ b/src/com/github/ivarref/yoltq/test_queue.clj @@ -1,4 +1,4 @@ -(ns com.github.ivarref.yoltq.virtual-queue +(ns com.github.ivarref.yoltq.test-queue (:require [clojure.tools.logging :as log] [com.github.ivarref.yoltq.report-queue :as rq] [com.github.ivarref.yoltq.ext-sys :as ext] @@ -161,7 +161,6 @@ (catch Throwable t# (log/error t# "unexpected error in consume-expect:" (ex-message t#)))) (test/is false (str "No job found for queue " ~queue-name)))) -tx-spent-time! (defmacro consume! [queue-name] `(consume-expect! ~queue-name :done)) @@ -181,7 +180,7 @@ tx-spent-time! nil))) -(defmacro consume-twice! [queue-name] +(defmacro force-retry! [queue-name] `(if-let [job# (get-tx-q-job ~queue-name)] (try (with-bindings (:com.github.ivarref.yoltq/bindings job#) |