Only handle requeued message in the relevant worker.
Add test for case of failing worker.