com.github.ivarref.yoltq.error-poller — com.github.ivarref/yoltq v0.2.82

do-poll-errors clj

(do-poll-errors
  {:keys [conn system-error on-system-error on-system-recovery healthy?
          healthy-allowed-error-time]
   :or {on-system-error
          (fn [] (log/error "There are yoltq queues which have errors") nil)
        on-system-recovery (fn [] (log/info "Yoltq recovered"))}
   :as config}
  now-ms)

get-state clj

(get-state v)

handle-error-count clj

(handle-error-count {:keys [errors last-notify state]
                     :or {errors [] last-notify 0 state :recovery}}
                    {:keys [system-error-min-count
                            system-error-callback-backoff]
                     :or {system-error-min-count 3}}
                    now-ms
                    error-count)

poll-errors clj

(poll-errors running? config-atom)