diff --git a/infra/mq/mq.c b/infra/mq/mq.c
index ddc598b..76ae081 100644
--- a/infra/mq/mq.c
+++ b/infra/mq/mq.c
@@ -117,7 +117,7 @@ static void mq_dispatch_one_message(struct mq_schema *s, struct mq_message *mq_e
         {
             if (sub_elt->msg_cb)
             {
-					if(topic->dispatch_cb)topic->dispatch_cb(mq_elt->header.topic_id,mq_elt->body, sub_elt->msg_cb, topic->dispatch_cb_arg, sub_elt->msg_cb_arg);
+					if(topic->dispatch_cb)topic->dispatch_cb(mq_elt->header.topic_id,mq_elt->body, sub_elt->msg_cb, sub_elt->msg_cb_arg, topic->dispatch_cb_arg);
 					else sub_elt->msg_cb(mq_elt->header.topic_id, mq_elt->body, sub_elt->msg_cb_arg);
             }
         }