From d89bf772a638c22339bdf523e9b5cf63c2eb2e07 Mon Sep 17 00:00:00 2001 From: Andrey Antukh Date: Mon, 22 Feb 2021 19:10:05 +0100 Subject: [PATCH] :sparkles: Add debug messages on notifications module. --- backend/src/app/msgbus.clj | 2 ++ backend/src/app/notifications.clj | 3 +++ 2 files changed, 5 insertions(+) diff --git a/backend/src/app/msgbus.clj b/backend/src/app/msgbus.clj index ba38f76a3..791604ce3 100644 --- a/backend/src/app/msgbus.clj +++ b/backend/src/app/msgbus.clj @@ -64,6 +64,8 @@ sub-buff (a/chan 1) cch (a/chan 1)] + (log/debugf "initializing msgbus (uri: '%s')" (str uri)) + ;; Start the sending (publishing) loop (impl-publish-loop snd-conn snd-buff cch) diff --git a/backend/src/app/notifications.clj b/backend/src/app/notifications.clj index 61f198814..265b36e40 100644 --- a/backend/src/app/notifications.clj +++ b/backend/src/app/notifications.clj @@ -144,6 +144,7 @@ ws-send (mtx/wrap-counter ws-send mtx-messages ["send"])] (letfn [(on-connect [conn] + (log/debugf "on-connect %s" (:session-id cfg)) (mtx-aconn :inc) (let [sub (a/chan) ws (WebSocket. conn in out sub nil cfg)] @@ -164,12 +165,14 @@ (a/close! sub)))) (on-error [_conn _e] + (log/debugf "on-error %s" (:session-id cfg)) (mtx-aconn :dec) (mtx-sessions :observe (/ (inst-ms (dt/duration-between created-at (dt/now))) 1000.0)) (a/close! out) (a/close! in)) (on-close [_conn _status _reason] + (log/debugf "on-close %s" (:session-id cfg)) (mtx-aconn :dec) (mtx-sessions :observe (/ (inst-ms (dt/duration-between created-at (dt/now))) 1000.0)) (a/close! out)