- RoutingTable table = getLocalBucket().getData().copy();
- for (RpcRouter.RouteIdentifier<?, ?, ?> routeId : msg.getRouteIdentifiers()) {
- table.removeRoute(routeId);
- }
-
- updateLocalBucket(table);
+ LOG.debug("RemoveRoutes: {}", msg.getRouteIdentifiers());
+ updateLocalBucket(getLocalBucket().getData().removeRpcs(msg.getRouteIdentifiers()));