Send messages to potential subscribers

Signed-off-by: Marcel Müller <neikos@neikos.email>

1 files changed, 2 insertions, 0 deletions

diff --git a/src/server/mod.rs b/src/server/mod.rs
index 4446d72..0354363 100644
--- a/src/server/mod.rs
+++ b/src/server/mod.rs
@@ -400,6 +400,7 @@ impl<LH: LoginHandler, SH: SubscriptionHandler> MqttServer<LH, SH> {
                 let subscription_manager = server.subscription_manager.clone();
                 let client_id = client_id.clone();
                 let clients = server.clients.clone();
+                let extra_listener = server.extra_listeners.clone();
 
                 tokio::spawn(async move {
                     let client_id = client_id;
@@ -442,6 +443,7 @@ impl<LH: LoginHandler, SH: SubscriptionHandler> MqttServer<LH, SH> {
                                     *qos,
                                 );
 
+                                let _ = extra_listener.send(message.clone());
                                 subscription_manager.route_message(message).await;
 
                                 // Handle QoS 1/AtLeastOnce response