- final SchemaService schemaService = brokerSession.getService(SchemaService.class);
- final DOMRpcService rpcService = brokerSession.getService(DOMRpcService.class);
- schemaContext = schemaService.getGlobalContext();
- rpcManager = actorSystem.actorOf(RpcManager.props(schemaContext,
- rpcProvisionRegistry, rpcService, config), config.getRpcManagerName());
- schemaListenerRegistration = schemaService.registerSchemaContextListener(this);
- LOG.debug("rpc manager started");
- }