diff options
| author | yangwei <[email protected]> | 2024-10-12 18:05:19 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-10-12 18:05:19 +0800 |
| commit | 1caa5f938d21ba178d2460aba28863c1b94657c4 (patch) | |
| tree | f2b01c3dc0d33a36e5a1400ccbd5f789b46538e8 /src | |
| parent | 4e4f93388f63adfde1e34aa9b0ef9685221ca3cf (diff) | |
🐞 fix(mq subscibe): allow null msg_cbFix-mq-sub-allow-null-msg-cb
Diffstat (limited to 'src')
| -rw-r--r-- | src/plugin_manager/plugin_manager.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/plugin_manager/plugin_manager.c b/src/plugin_manager/plugin_manager.c index 57a2ff0..b56470b 100644 --- a/src/plugin_manager/plugin_manager.c +++ b/src/plugin_manager/plugin_manager.c @@ -809,7 +809,7 @@ inline int session_mq_unignore_message(struct session *sess, int topic_id, int p int stellar_session_mq_subscribe(struct stellar *st, int topic_id, on_session_msg_cb_func *plugin_on_msg_cb, int plugin_id) { - if(plugin_id >= PACKET_PULGIN_ID_BASE || plugin_on_msg_cb == NULL)return -1;// ignore packet plugin + if(plugin_id >= PACKET_PULGIN_ID_BASE)return -1;// ignore packet plugin struct plugin_manager_schema *plug_mgr = stellar_plugin_manager_schema_get(st); if(plug_mgr == NULL || plug_mgr->registered_session_plugin_array == NULL)return -1; |