- public void testInitRegisterTapiToRpcRegistry() {
- TapiProvider provider = new TapiProvider(getDataBroker(), rpcProviderRegistry, serviceHandler,
- serviceDataStoreOperations, tapiListener, networkTransactionService, topologyListener,
- tapiPortMappingListener, tapiNetworkUtils, pceListenerImpl, rendererListenerImpl,
- serviceHandlerListenerImpl, getNotificationService());
-
- provider.init();
-
- verify(rpcProviderRegistry, times(1))
- .registerRpcImplementation(any(), any(TapiConnectivityService.class));
- verify(rpcProviderRegistry, times(2))
- .registerRpcImplementation(any(), any(TapiTopologyService.class));
- verify(rpcProviderRegistry, times(2))
- .registerRpcImplementation(any(), any(TapiCommonService.class));
- }
-
- @After
- public void releaseMocks() throws Exception {
- closeable.close();
+ void testInitRegisterTapiToRpcRegistry() {
+ when(networkTransactionService.read(any(), any())).thenReturn(Futures.immediateFuture(Optional.empty()));
+ doReturn(emptyFluentFuture()).when(networkTransactionService).commit();
+ new TapiProvider(dataBroker, rpcProviderRegistry, notificationService, notificationPublishService,
+ networkTransactionService, serviceHandler, serviceDataStoreOperations,
+ tapiNetworkModelNotificationHandler, tapiNetworkModelServiceImpl);
+
+ verify(rpcProviderRegistry, times(2)).registerRpcImplementations(any());
+ verify(dataBroker, times(4)).registerDataTreeChangeListener(any(), any());