GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore(manager): remove notify app sub/unsub

Browse Source
This commit is contained in:
fengzero
2022-08-24 05:53:22 +00:00
parent b38a40c8ec
commit 23be6a9e1f
8 changed files with 0 additions and 180 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/ekuiper/plugin_ekuiper.c
-7
View File
@@ -172,13 +172,6 @@ static int ekuiper_plugin_request(neu_plugin_t * plugin,
send_data(plugin, trans_data);
break;
}
case NEU_RESP_APP_SUBSCRIBE_GROUP: {
neu_resp_app_subscribe_group_t *sub =
(neu_resp_app_subscribe_group_t *) data;
utarray_free(sub->tags);
break;
}
default:
plog_notice(plugin, "unsupported request type: %d", header->type);
break;
plugins/mqtt/mqtt_plugin.c
-17
View File
@@ -516,19 +516,6 @@ static neu_err_code_e trans_data(neu_plugin_t *plugin, void *data)
return NEU_ERR_SUCCESS;
}
static neu_err_code_e subscribe_handle(neu_plugin_t * plugin,
neu_reqresp_head_t *head, void *data)
{
UNUSED(plugin);
UNUSED(head);
neu_resp_app_subscribe_group_t *sub =
(neu_resp_app_subscribe_group_t *) data;
utarray_free(sub->tags);
return NEU_ERR_SUCCESS;
}
static neu_err_code_e node_state_send(neu_plugin_t * plugin,
neu_reqresp_head_t *head, void *data)
{
@@ -585,10 +572,6 @@ static int mqtt_plugin_request(neu_plugin_t *plugin, neu_reqresp_head_t *head,
case NEU_REQRESP_TRANS_DATA:
error = trans_data(plugin, data);
break;
case NEU_RESP_APP_SUBSCRIBE_GROUP: {
error = subscribe_handle(plugin, head, data);
break;
}
case NEU_REQRESP_NODES_STATE: {
error = node_state_send(plugin, head, data);
break;