import java.util.Arrays;
import java.util.Objects;
import java.util.Optional;
-import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.checkerframework.checker.lock.qual.GuardedBy;
import org.opendaylight.bgpcep.programming.spi.InstructionScheduler;
import org.opendaylight.bgpcep.topology.DefaultTopologyReference;
import org.opendaylight.mdsal.binding.api.RpcProviderService;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.programming.rev181109.NetworkTopologyPcepProgrammingService;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev220730.NetworkTopologyPcepService;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
import org.opendaylight.yangtools.concepts.Registration;
// Register RPCs
final RpcProviderService rpcRegistry = dependencies.getRpcProviderRegistry();
- elementReg = rpcRegistry.registerRpcImplementation(NetworkTopologyPcepService.class,
- new TopologyRPCs(manager), Set.of(instanceIdentifier));
- networkReg = rpcRegistry.registerRpcImplementation(NetworkTopologyPcepProgrammingService.class,
- new TopologyProgramming(scheduler, manager), Set.of(instanceIdentifier));
+ elementReg = new TopologyRPCs(manager).register(rpcRegistry, instanceIdentifier);
+ networkReg = new TopologyProgramming(scheduler, manager).register(rpcRegistry, instanceIdentifier);
// We are now completely initialized
LOG.info("PCEP Topology Provider {} enabled", topologyId());