diff options
| author | yangwei <[email protected]> | 2024-09-04 11:19:50 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-09-04 11:19:50 +0800 |
| commit | e14a140768aecb11ee7c4127a58e1d7d2fa1013d (patch) | |
| tree | 25b1cb7f300a10fd66ecf218e487874572f31b3f | |
| parent | 654718c56f50616fdcb38d9e26e2b11e99aea5e3 (diff) | |
🐞 fix(plugin_manager on session closing): pub msg on intrinsic output topic
| -rw-r--r-- | infra/plugin_manager/plugin_manager.c | 2 |
1 files changed, 2 insertions, 0 deletions
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; |