dt_msg_queue_submit
dt_msg_queue_submit(env->msgqueue, buf, len_buf);
void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len);