Add a message queue for consumer which would help in case ultimate user restarts abnormally.