named notifications loop thread

src/app/mod.rs

@@ -55,13 +55,16 @@ pub(crate) async fn run(db: &ConnectionPool, authz_cache: Option<AuthzCache>) ->
     // Event loop for incoming messages of MQTT Agent
     let (mq_tx, mut mq_rx) = futures_channel::mpsc::unbounded::<AgentNotification>();
 
-    thread::spawn(move || {
-        for message in rx {
-            if let Err(_) = mq_tx.unbounded_send(message) {
-                error!("Error sending message to the internal channel");
+    thread::Builder::new()
+        .name("conference-notifications-loop".to_owned())
+        .spawn(move || {
+            for message in rx {
+                if let Err(_) = mq_tx.unbounded_send(message) {
+                    error!("Error sending message to the internal channel");
+                }
             }
-        }
-    });
+        })
+        .expect("Failed to start conference notifications loop");
 
     // Authz
     let authz = svc_authz::ClientMap::new(&config.id, authz_cache, config.authz.clone())