mirror of
https://github.com/emqx/neuron.git
synced 2026-10-22 01:05:56 +08:00
Update adapter event_notify to send tags add/del/update events
This commit is contained in:
@@ -1423,6 +1423,24 @@ static int adapter_event_notify(neu_adapter_t * adapter,
|
||||
|
||||
log_info("Get event notify from plugin");
|
||||
switch (event->type) {
|
||||
case NEU_EVENT_ADD_TAGS: {
|
||||
ADAPTER_SEND_BUF(adapter, rv, MSG_EVENT_ADD_TAGS, event->buf,
|
||||
event->buf_len);
|
||||
break;
|
||||
}
|
||||
|
||||
case NEU_EVENT_UPDATE_TAGS: {
|
||||
ADAPTER_SEND_BUF(adapter, rv, MSG_EVENT_UPDATE_TAGS, event->buf,
|
||||
event->buf_len);
|
||||
break;
|
||||
}
|
||||
|
||||
case NEU_EVENT_DEL_TAGS: {
|
||||
ADAPTER_SEND_BUF(adapter, rv, MSG_EVENT_ADD_TAGS, event->buf,
|
||||
event->buf_len);
|
||||
break;
|
||||
}
|
||||
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user