- if(LOG.isDebugEnabled()) {
- LOG.debug("Removing registration for [{}]", rpcs);
- }
- final List<RpcRouter.RouteIdentifier<?,?,?>> routeIds = new ArrayList<>();
- for (final DOMRpcIdentifier rpc : rpcs) {
- final RpcRouter.RouteIdentifier<?,?,?> routeId = new RouteIdentifierImpl(null, rpc.getType().getLastComponent(), rpc.getContextReference());
- routeIds.add(routeId);
- }
- final RpcRegistry.Messages.RemoveRoutes removeRpcMsg = new RpcRegistry.Messages.RemoveRoutes(routeIds);
- rpcRegistry.tell(removeRpcMsg, ActorRef.noSender());
+
+ LOG.debug("Removing registration for [{}]", rpcs);
+ rpcRegistry.tell(new RemoveRoutes(rpcs), ActorRef.noSender());
+ }
+
+ @Override
+ public boolean acceptsImplementation(final DOMRpcImplementation impl) {
+ return !(impl instanceof RemoteRpcImplementation);