From e14a140768aecb11ee7c4127a58e1d7d2fa1013d Mon Sep 17 00:00:00 2001 From: yangwei Date: Wed, 4 Sep 2024 11:19:50 +0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9E=20fix(plugin=5Fmanager=20on=20sess?= =?UTF-8?q?ion=20closing):=20pub=20msg=20on=20intrinsic=20output=20topic?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- infra/plugin_manager/plugin_manager.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/infra/plugin_manager/plugin_manager.c b/infra/plugin_manager/plugin_manager.c index 634665a..31832c6 100644 --- a/infra/plugin_manager/plugin_manager.c +++ b/infra/plugin_manager/plugin_manager.c @@ -1075,9 +1075,11 @@ void plugin_manager_on_session_closing(struct session *sess) case SESSION_TYPE_TCP: session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->tcp_input_topic_id ,NULL, STELLAR_MQ_PRIORITY_HIGH); session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->tcp_stream_topic_id , NULL, STELLAR_MQ_PRIORITY_HIGH); + session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->tcp_output_topic_id , NULL, STELLAR_MQ_PRIORITY_HIGH); break; case SESSION_TYPE_UDP: session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->udp_input_topic_id ,NULL, STELLAR_MQ_PRIORITY_HIGH); + session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->udp_output_topic_id ,NULL, STELLAR_MQ_PRIORITY_HIGH); break; default: break;