diff options
| author | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-17 22:16:14 +0200 |
|---|---|---|
| committer | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-17 22:16:14 +0200 |
| commit | 2a236e6d90410821370761434fad45b13621fbdf (patch) | |
| tree | 2950201cc14368bffbd3aedb6fcefb71cc6c90af /test | |
| parent | Use [#'taoensso.timbre/*context*] as default :capture-bindings if present (diff) | |
| download | fiinha-2a236e6d90410821370761434fad45b13621fbdf.tar.gz fiinha-2a236e6d90410821370761434fad45b13621fbdf.tar.xz | |
Add consume-twice! test function for verifying idempotence
Diffstat (limited to 'test')
| -rw-r--r-- | test/com/github/ivarref/yoltq/virtual_test.clj | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/test/com/github/ivarref/yoltq/virtual_test.clj b/test/com/github/ivarref/yoltq/virtual_test.clj index 3c7c5b4..5e5fc92 100644 --- a/test/com/github/ivarref/yoltq/virtual_test.clj +++ b/test/com/github/ivarref/yoltq/virtual_test.clj @@ -20,7 +20,7 @@ (dq/init! {:conn conn}) (dq/add-consumer! :q identity) @(d/transact conn [(dq/put :q {:work 123})]) - (is (= {:work 123} (:retval (vq/run-queue-once! :q :init)))))) + (is (= {:work 123} (vq/consume! :q))))) (deftest happy-case-tx-report-q @@ -274,3 +274,12 @@ (binding [timbre/*context* {:x-request-id "123"}] @(d/transact conn [(dq/put :q nil)])) (is (= "123" (vq/consume-expect! :q :done))))) + + +(deftest consume-twice + (let [conn (u/empty-conn) + cnt (atom 0)] + (yq/init! {:conn conn}) + (yq/add-consumer! :q (fn [_] (swap! cnt inc))) + @(d/transact conn [(dq/put :q nil)]) + (is (= 2 (vq/consume-twice! :q))))) |