- OrgOpenroadmServiceService serviceHandler = new ServicehandlerImpl(rpcProviderService, pathComputationService,
- rendererServiceOperations, notificationPublishService, pceListenerImpl, rendererListenerImpl,
- networkModelListenerImpl, serviceDataStoreOperations, catalogDataStoreOperations);
-
- TapiConnectivityImpl tapiConnectivity = new TapiConnectivityImpl(serviceHandler, tapiContext, connectivityUtils,
- tapipceListenerImpl, tapirendererListenerImpl);
-
- ListenableFuture<RpcResult<CreateConnectivityServiceOutput>> result =
- tapiConnectivity.createConnectivityService(new CreateConnectivityServiceInputBuilder().build());
+ when(rpcService.getRpc(any()))
+ .thenReturn(new CreateConnectivityServiceImpl(rpcService, tapiContext, connectivityUtils,
+ tapipceNotificationHandler, tapirendererNotificationHandler));
+ ListenableFuture<RpcResult<CreateConnectivityServiceOutput>> result = rpcService
+ .getRpc(CreateConnectivityService.class).invoke(new CreateConnectivityServiceInputBuilder().build());