From bf65690cdf8e097af2a29acf692be757a04eae57 Mon Sep 17 00:00:00 2001 From: yangwei Date: Sat, 14 Sep 2024 15:52:54 +0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9E=20fix(mq):=20fix=20dispatch=20para?= =?UTF-8?q?meter=20seq=20by=20mistake?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- infra/mq/mq.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); } }