public/milquetoast
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: Add structured logging to client.clj using clojure.tools.logging

Browse Source
This commit is contained in:
niten" (aider) 2025-06-08 08:29:08 -07:00
parent 8d29796f18
commit d92cab7adb
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/milquetoast/client.clj
View File

@ -1,7 +1,8 @@
(ns milquetoast.client
(:require [clojure.core.async :as async :refer [go go-loop <! >! alts!! <!! timeout]]
[clojure.data.json :as json]
[clojure.core.async.impl.runtime])
[clojure.core.async.impl.runtime]
[clojure.tools.logging :as log])
(:import [org.eclipse.paho.client.mqttv3 MqttClient MqttConnectOptions MqttMessage IMqttMessageListener]
org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
java.time.Instant))
@ -35,7 +36,7 @@
(println (format "attempt failed, attempting reconnect")))
(reconnect)
(when verbose
(println (format "sleeping %s ms" wait-ms)))
(log/debug (format "sleeping %s ms" wait-ms)))
(<!! (timeout wait-ms))
(recur (wrapped-attempt) (min (* wait-ms 1.25) max-wait)))))))
@ -71,7 +72,7 @@
#(.reconnect client)))
(stop! [_]
(when verbose
(println
(log/info
(str "stopping " (count @open-channels) " channels")))
(doseq [chan @open-channels]
(async/close! chan))