parent
321935e8ca
commit
87159dca7e
|
@ -207,12 +207,10 @@
|
||||||
|
|
||||||
(defn reset-pending-messages! [to]
|
(defn reset-pending-messages! [to]
|
||||||
(doseq [key (@recipient->pending-message to)]
|
(doseq [key (@recipient->pending-message to)]
|
||||||
(swap! messages
|
(when (get-in @messages key)
|
||||||
(fn [messages]
|
(swap! messages #(update-in % key assoc
|
||||||
(when (get-in messages key)
|
:last-attempt 0
|
||||||
(update-in messages key assoc
|
:attempts 0)))))
|
||||||
:last-attempt 0
|
|
||||||
:attempts 0))))))
|
|
||||||
|
|
||||||
(defn reset-all-pending-messages! []
|
(defn reset-all-pending-messages! []
|
||||||
(reset! messages {}))
|
(reset! messages {}))
|
||||||
|
|
Loading…
Reference in New Issue