feat: add blocking? option on creation

moclojer · Jul 15, 2024 · 74e0211 · 74e0211
1 parent 240b8b2
commit 74e0211
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/com/moclojer/components/core.clj b/src/com/moclojer/components/core.clj
@@ -30,11 +30,12 @@
 (def setup-logger logs/setup)
 
 (defn new-mq
-  ([workers]
-   (new-mq workers []))
-  ([workers jobs]
+  ([workers blocking?]
+   (new-mq workers [] blocking?))
+  ([workers jobs blocking?]
    (mq/map->MQ {:workers workers
-                :jobs jobs})))
+                :jobs jobs
+                :blocking? blocking?})))
 
 (defn new-mq-mock
   []

diff --git a/src/com/moclojer/components/mq.clj b/src/com/moclojer/components/mq.clj
@@ -102,7 +102,7 @@
               (Thread/sleep sleep)
               (recur (inc attempt)))))))))
 
-(defonce mock-channels (atom {}))
+(def mock-channels (atom {}))
 
 (defn mock-op-name->op-fn
   "Adapts given mq `operation name` to its relative function."