// Updating internal structure of registration
routingTable.updateRoute(path, registration.instance)
+ // Update routing table / send announce to message bus
+
val success = paths.put(context, path);
}
}
}
+
+ def createDelegate(Class<? extends RpcService> type) {
+ getManagedDirectProxy(type);
+ }
+
}
class RoutedRpcRegistrationImpl<T extends RpcService> extends AbstractObjectRegistration<T> implements RoutedRpcRegistration<T> {