To handle edge cases where there is an issue decoding and parsing the incoming message; in such cases, the message would be stuck in a phantom state as they would not be deleted by the worker.
What I changed
Wrap the entire message processing code in a try/catch block, with errors being logged and the message being deleted from the queue.
Closes #57.
Goal
To handle edge cases where there is an issue decoding and parsing the incoming message; in such cases, the message would be stuck in a phantom state as they would not be deleted by the worker.
What I changed
Wrap the entire message processing code in a try/catch block, with errors being logged and the message being deleted from the queue.