X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=networkmodel%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fnetworkmodel%2FNetworkModelProvider.java;h=d1ef447cb756fc213f5448b6426428917c9710a7;hb=90f34a652cd45f0c313d0426d89359c8cf9f29ba;hp=a1c359452bed1a0c0172a55a1ba5dd54a0e0e94b;hpb=4d94935b354ae96badf10d8f70dd293a34f8c2d2;p=transportpce.git diff --git a/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetworkModelProvider.java b/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetworkModelProvider.java index a1c359452..d1ef447cb 100644 --- a/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetworkModelProvider.java +++ b/networkmodel/src/main/java/org/opendaylight/transportpce/networkmodel/NetworkModelProvider.java @@ -9,11 +9,9 @@ package org.opendaylight.transportpce.networkmodel; import java.util.ArrayList; import java.util.List; -import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.binding.api.DataTreeIdentifier; import org.opendaylight.mdsal.binding.api.NotificationService; -import org.opendaylight.mdsal.binding.api.RpcProviderService; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.transportpce.common.InstanceIdentifiers; import org.opendaylight.transportpce.common.NetworkUtils; @@ -25,7 +23,6 @@ import org.opendaylight.transportpce.networkmodel.listeners.ServiceHandlerListen import org.opendaylight.transportpce.networkmodel.service.FrequenciesService; import org.opendaylight.transportpce.networkmodel.service.NetworkModelService; import org.opendaylight.transportpce.networkmodel.util.TpceNetwork; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630.TransportpceNetworkutilsService; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.Network; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220922.mapping.Mapping; import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.servicehandler.rev201125.TransportpceServicehandlerListener; @@ -50,11 +47,8 @@ public class NetworkModelProvider { .child(Mapping.class); private final DataBroker dataBroker; - private final RpcProviderService rpcProviderService; - private final TransportpceNetworkutilsService networkutilsService; private final NetConfTopologyListener topologyListener; private List listeners; - private @NonNull Registration networkutilsServiceRpcRegistration; private TpceNetwork tpceNetwork; private ListenerRegistration serviceHandlerListenerRegistration; private NotificationService notificationService; @@ -64,18 +58,15 @@ public class NetworkModelProvider { @Activate public NetworkModelProvider(@Reference NetworkTransactionService networkTransactionService, @Reference final DataBroker dataBroker, - @Reference final RpcProviderService rpcProviderService, @Reference final NetworkModelService networkModelService, @Reference DeviceTransactionManager deviceTransactionManager, @Reference PortMapping portMapping, @Reference NotificationService notificationService, @Reference FrequenciesService frequenciesService) { this.dataBroker = dataBroker; - this.rpcProviderService = rpcProviderService; this.notificationService = notificationService; this.frequenciesService = frequenciesService; this.listeners = new ArrayList<>(); - this.networkutilsService = new NetworkUtilsImpl(dataBroker); this.topologyListener = new NetConfTopologyListener(networkModelService, dataBroker, deviceTransactionManager, portMapping); this.tpceNetwork = new TpceNetwork(networkTransactionService); @@ -97,8 +88,6 @@ public class NetworkModelProvider { InstanceIdentifiers.NETCONF_TOPOLOGY_II.child(Node.class)), topologyListener)); listeners.add(dataBroker.registerDataTreeChangeListener( DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, MAPPING_II), portMappingListener)); - networkutilsServiceRpcRegistration = rpcProviderService - .registerRpcImplementation(TransportpceNetworkutilsService.class, networkutilsService); TransportpceServicehandlerListener serviceHandlerListner = new ServiceHandlerListener(frequenciesService); serviceHandlerListenerRegistration = notificationService.registerNotificationListener(serviceHandlerListner); } @@ -111,9 +100,6 @@ public class NetworkModelProvider { LOG.info("NetworkModelProvider Closed"); listeners.forEach(lis -> lis.close()); listeners.clear(); - if (networkutilsServiceRpcRegistration != null) { - networkutilsServiceRpcRegistration.close(); - } serviceHandlerListenerRegistration.close(); } }