Added the ability to remove routes from router.

2026-04-03 09:36:00 -04:00
parent 900ce1f7e7
commit 1bc0242d00
1 changed files with 6 additions and 0 deletions
--- a/src/queue/data_director.rs
+++ b/src/queue/data_director.rs
@@ -56,6 +56,7 @@ pub enum RegMsg {
    Error(MTTError),
    GetNameID(Name),
    Ok,
+    RemoveRoute(Route),
    RemoveSender(SenderID),
    RouteID(RouteID),
 }
@@ -564,6 +565,11 @@ impl DocRegistry {
                self.routes.remove_sender_id(sender_id);
                reg.response(RegMsg::Ok)
            }
+            RegMsg::RemoveRoute(route) => {
+                self.routes
+                    .remove_route(route.clone(), reg.get_sender_id().clone());
+                reg.response(RegMsg::Ok)
+            }
            _ => reg.response(RegMsg::Ok),
        }
    }