- rpcManager = new RpcManagerImpl(rpcProviderRegistry, QUOTA_VALUE, conductor);
- rpcManager.setDeviceInitializationPhaseHandler(deviceINitializationPhaseHandler);
- Mockito.when(deviceContext.getDeviceState()).thenReturn(deviceState);
- Mockito.when(deviceContext.getMessageSpy()).thenReturn(mockMsgSpy);
- Mockito.when(deviceState.getNodeId()).thenReturn(nodeKey.getId());
- Mockito.when(conductor.getDeviceContext(Mockito.<NodeId>any())).thenReturn(deviceContext);
+ rpcManager = new RpcManagerImpl(new OpenflowProviderConfigBuilder()
+ .setRpcRequestsQuota(new NonZeroUint16Type(QUOTA_VALUE))
+ .setIsStatisticsRpcEnabled(false)
+ .build(),
+ rpcProviderRegistry, extensionConverterProvider, convertorExecutor, notificationPublishService);
+
+ FeaturesReply features = new GetFeaturesOutputBuilder()
+ .setVersion(OFConstants.OFP_VERSION_1_3)
+ .build();
+
+ Mockito.when(deviceInfo.getNodeInstanceIdentifier()).thenReturn(nodePath);
+ Mockito.when(deviceContext.getDeviceInfo()).thenReturn(deviceInfo);
+ Mockito.when(deviceContext.getMessageSpy()).thenReturn(messageSpy);