Could you explain more about the message queue? How it was implemented, why do you decided to change it and what's the new setup?