Added message queue publish/subscribe