diff --git a/src/queue/data_director.rs b/src/queue/data_director.rs index 2529ad5..a73e698 100644 --- 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), } }