fix(go): send mq messages in go routine;