taoensso / carmine

Redis client + message queue for Clojure
https://www.taoensso.com/carmine
Eclipse Public License 1.0
1.15k stars 130 forks source link

how do you deal with locked jobs when a message is dropped ? #214

Closed jdkealy closed 5 years ago

jdkealy commented 5 years ago

Hi,

In the middle of a code deploy about 30 messages were in the middle of being processed and were dropped in the middle of execution.

When i evaluate

  (:nattempts  (car-mq/queue-status redis/server-connection queue-name))

i've seen the same response for like 30 minutes now

{"bfa-17592211972445" "1", "bfa-17592211972515" "1", "bfa-17592211972441" "1", "bfa-17592211972502" "1", "bfa-17592211972516" "1", "bfa-17592211972512" "1", "bfa-17592211972509" "1", "bfa-17592211972519" "1", "bfa-17592211972440" "1", "bfa-17592211972448" "1", "bfa-17592211972506" "1", "bfa-17592211972447" "1", "bfa-17592211972508" "1", "bfa-17592211972510" "1", "bfa-17592211972513" "1", "bfa-17592211972507" "1", "bfa-17592211972514" "1", "bfa-17592211972500" "1", "bfa-17592211972498" "1", "bfa-17592211972504" "1", "bfa-17592211972518" "1", "bfa-17592211972229" "1", "bfa-17592211972442" "1", "bfa-17592211972511" "1", "bfa-17592211972503" "1", "bfa-17592211972505" "1", "bfa-17592211972517" "1", "bfa-17592211972449" "1", "bfa-17592211972501" "1", "bfa-17592211972446" "1"}

No jobs should actually take any longer than a minute. Is there a way to retry these after they have been sitting around for a period of time?

jdkealy commented 5 years ago

Sorry about that. Just read the code. lock-ms seems to be what i'm after. Thanks.