- public void initTest() {
- NbiNotificationsProvider provider = new NbiNotificationsProvider(
- Arrays.asList("topic1", "topic2"), "localhost:8080", "localhost:8080",
- rpcProviderRegistry, notificationService,
- getDataStoreContextUtil().getBindingDOMCodecServices());
- provider.init();
- verify(rpcProviderRegistry, times(1))
- .registerRpcImplementation(any(), any(NbiNotificationsImpl.class));
+ void initTest() {
+ networkTransactionService = new NetworkTransactionImpl(getDataBroker());
+ new NbiNotificationsProvider("localhost:8080", "localhost:8080",
+ rpcProviderRegistry, notificationService, getDataStoreContextUtil().getBindingDOMCodecServices(),
+ networkTransactionService);
+ verify(rpcProviderRegistry, times(1)).registerRpcImplementations(any(ClassToInstanceMap.class));