diff options
| author | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-24 10:59:06 +0200 |
|---|---|---|
| committer | Ivar Refsdal <ivar.refsdal@nsd.no> | 2021-09-24 10:59:06 +0200 |
| commit | e142149a4282a669f3f95cb52f708d234a8ded23 (patch) | |
| tree | cce23f9c28e31b53177bcf8ce6ab2e9a4266a995 /test | |
| parent | Be paranoid when persisting with pr-str (diff) | |
| download | fiinha-e142149a4282a669f3f95cb52f708d234a8ded23.tar.gz fiinha-e142149a4282a669f3f95cb52f708d234a8ded23.tar.xz | |
Support :depends-on on queue level
Diffstat (limited to 'test')
| -rw-r--r-- | test/com/github/ivarref/yoltq/virtual_test.clj | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/test/com/github/ivarref/yoltq/virtual_test.clj b/test/com/github/ivarref/yoltq/virtual_test.clj index fdbf6b3..3f7365f 100644 --- a/test/com/github/ivarref/yoltq/virtual_test.clj +++ b/test/com/github/ivarref/yoltq/virtual_test.clj @@ -309,6 +309,21 @@ (is (= {:id "b1"} (tq/consume! :b))))) +(deftest depends-on-queue-level + (let [conn (u/empty-conn)] + (yq/init! {:conn conn}) + (yq/add-consumer! :a identity) + (yq/add-consumer! :b identity {:depends-on (fn [{:keys [id]}] [:a id])}) + @(d/transact conn [(yq/put :a {:id "1"} {:id "1"})]) + @(d/transact conn [(yq/put :b {:id "1"})]) + + ; can't consume :b yet: + (is (= {:depends-on [:a "1"]} (tq/consume! :b))) + + (is (= {:id "1"} (tq/consume! :a))) + (is (= {:id "1"} (tq/consume! :b))))) + + (deftest verify-can-read-string (let [conn (u/empty-conn)] (yq/init! {:conn conn}) |