[worker] [BUG] delete message after it is resent

parent 307f6760
Pipeline #6916 failed with stages
in 59 seconds
......@@ -94,6 +94,7 @@ runSingle' state@(State { .. }) = do
when (resendWhenWorkerKilled mdata) $ do
-- putStrLn $ formatStr state $ "resending job: " <> show job
void $ sendJob broker queueName (job { metadata = mdata { readCount = readCount mdata + 1 } })
void $ deleteMessage broker queueName $ messageId brokerMessage
-- size <- getQueueSize broker queueName
-- putStrLn $ formatStr state $ "queue size: " <> show size
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment