Create DLQ service that consumes the messages that could not be processed and save it to local storage