clean up error logging
This commit is contained in:
parent
2fc27341fe
commit
3a49cf561f
|
@ -114,8 +114,7 @@
|
||||||
(swap! view-system update-hash! view-sig data-hash)
|
(swap! view-system update-hash! view-sig data-hash)
|
||||||
(send-view-data! subscriber-key view-sig vdata)))
|
(send-view-data! subscriber-key view-sig vdata)))
|
||||||
(catch Exception e
|
(catch Exception e
|
||||||
(error "error subscribing:" namespace view-id parameters
|
(error e "error subscribing to view" view-sig)))))
|
||||||
"e:" e "msg:" (.getMessage e))))))
|
|
||||||
(do
|
(do
|
||||||
(trace "subscription not authorized" view-sig subscriber-key context)
|
(trace "subscription not authorized" view-sig subscriber-key context)
|
||||||
(on-unauthorized-subscription view-sig subscriber-key context)
|
(on-unauthorized-subscription view-sig subscriber-key context)
|
||||||
|
@ -205,8 +204,8 @@
|
||||||
(do
|
(do
|
||||||
(when (collect-stats?) (swap! statistics update-in [:deduplicated] inc))
|
(when (collect-stats?) (swap! statistics update-in [:deduplicated] inc))
|
||||||
(trace "already queued for refresh" view-sig))))
|
(trace "already queued for refresh" view-sig))))
|
||||||
(catch Exception e (error "error determining if view is relevant, view-id:"
|
(catch Exception e
|
||||||
view-id "e:" e))))))
|
(error e "error determining if view is relevant" view-sig))))))
|
||||||
|
|
||||||
(defn subscribed-views
|
(defn subscribed-views
|
||||||
"Returns a list of all views in the system that have subscribers."
|
"Returns a list of all views in the system that have subscribers."
|
||||||
|
@ -264,8 +263,7 @@
|
||||||
(send-view-data! subscriber-key view-sig vdata))
|
(send-view-data! subscriber-key view-sig vdata))
|
||||||
(swap! view-system assoc-in [:hashes view-sig] hdata)))
|
(swap! view-system assoc-in [:hashes view-sig] hdata)))
|
||||||
(catch Exception e
|
(catch Exception e
|
||||||
(error "error refreshing:" namespace view-id parameters
|
(error e "error refreshing:" namespace view-id parameters))))
|
||||||
"e:" e "msg:" (.getMessage e)))))
|
|
||||||
(catch InterruptedException e))
|
(catch InterruptedException e))
|
||||||
(if-not (:stop-workers? @view-system)
|
(if-not (:stop-workers? @view-system)
|
||||||
(recur)
|
(recur)
|
||||||
|
@ -285,7 +283,7 @@
|
||||||
(wait last-update min-refresh-interval))
|
(wait last-update min-refresh-interval))
|
||||||
(catch InterruptedException e)
|
(catch InterruptedException e)
|
||||||
(catch Exception e
|
(catch Exception e
|
||||||
(error "exception in views e:" e "msg:" (.getMessage e))))
|
(error e "exception in views")))
|
||||||
(if-not (:stop-refresh-watcher? @view-system)
|
(if-not (:stop-refresh-watcher? @view-system)
|
||||||
(recur)
|
(recur)
|
||||||
(trace "exiting refresh watcher thread")))))
|
(trace "exiting refresh watcher thread")))))
|
||||||
|
|
Loading…
Reference in a new issue