public void startQueryService ( RpcService rpcService , ResourceID resourceID ) { synchronized ( lock ) { Preconditions . checkState ( ! isShutdown ( ) , "The metric registry has already been shut down." ) ; try { metricQueryServiceRpcService = rpcService ; queryService = MetricQueryService . createMetricQueryService ( rpcService , resourceID , maximumFramesize ) ; queryService . start ( ) ; } catch ( Exception e ) { LOG . warn ( "Could not start MetricDumpActor. No metrics will be submitted to the WebInterface." , e ) ; } } }
Initializes the MetricQueryService .