Merge remote-tracking branch 'upstream/main', where "upstream" is yoltq.

1 files changed, 48 insertions, 0 deletions

diff --git a/test/com/github/ivarref/yoltq/readme_demo.clj b/test/com/github/ivarref/yoltq/readme_demo.clj
new file mode 100644
index 0000000..eae0a3e
--- /dev/null
+++ b/test/com/github/ivarref/yoltq/readme_demo.clj
@@ -0,0 +1,48 @@
+(ns com.github.ivarref.yoltq.readme-demo
+  (:require [clojure.tools.logging :as log]
+            [datomic.api :as d]
+            [com.github.ivarref.yoltq :as yq])
+  (:import (java.util UUID)))
+
+
+(defonce conn
+  (let [uri (str "datomic:mem://hello-world-" (UUID/randomUUID))]
+    (d/delete-database uri)
+    (d/create-database uri)
+    (d/connect uri)))
+
+
+(com.github.ivarref.yoltq.log-init/init-logging!
+  [[#{"datomic.*" "com.datomic.*" "org.apache.*"} :warn]
+   [#{"com.github.ivarref.yoltq.report-queue"} :debug]
+   [#{"com.github.ivarref.yoltq.poller"} :info]
+   [#{"com.github.ivarref.yoltq*"} :debug]
+   [#{"*"} :info]])
+
+
+(yq/stop!)
+
+(yq/init! {:conn conn})
+
+
+(yq/add-consumer! :q
+                  (let [cnt (atom 0)]
+                    (fn [payload]
+                      (when (= 1 (swap! cnt inc))
+                        (throw (ex-info "failed" {})))
+                      (log/info "got payload" payload))))
+
+(yq/start!)
+
+@(d/transact conn [(yq/put :q {:work 123})])
+
+(comment
+  (yq/add-consumer! :q (fn [_] (throw (ex-info "always fail" {})))))
+
+(comment
+  @(d/transact conn [(yq/put :q {:work 123})]))
+
+(comment
+  (do
+    (yq/add-consumer! :q (fn [_] :ok))
+    nil))