Trigger rapid publishing of messages.

3 years ago · a2be6cc9b1
parent b873e1d5d6
commit a2be6cc9b1
1 changed files with 1 additions and 0 deletions
--- a/src/plugin_public.c
+++ b/src/plugin_public.c
@ -243,6 +243,7 @@ BROKER_EXPORT int mosquitto_broker_publish(

 	DL_APPEND(db.plugin_msgs, msg);

+	loop__update_next_event(1);
 	return MOSQ_ERR_SUCCESS;
 }