- maxRequestsQuota = quotaValue;
- this.conductor = lifecycleConductor;
- }
-
- @Override
- public void setDeviceInitializationPhaseHandler(final DeviceInitializationPhaseHandler handler) {
- deviceInitPhaseHandler = handler;
- }
-
- @Override
- public void onDeviceContextLevelUp(final DeviceInfo deviceInfo) throws Exception {
-
- final DeviceContext deviceContext = Preconditions.checkNotNull(conductor.getDeviceContext(deviceInfo));
-
- final RpcContext rpcContext = new RpcContextImpl(
- rpcProviderRegistry,
- deviceContext,
- deviceContext.getMessageSpy(),
- maxRequestsQuota,
- deviceInfo.getNodeInstanceIdentifier());
-
- deviceContext.setRpcContext(rpcContext);
-
- Verify.verify(contexts.putIfAbsent(deviceInfo, rpcContext) == null, "RpcCtx still not closed for node {}", deviceInfo.getNodeId());
-
- // finish device initialization cycle back to DeviceManager
- deviceInitPhaseHandler.onDeviceContextLevelUp(deviceInfo);
+ this.extensionConverterProvider = extensionConverterProvider;
+ this.convertorExecutor = convertorExecutor;
+ this.notificationPublishService = notificationPublishService;