public void onInternalMessage ( Metrics . MetricPublisher request , Metrics . MetricPublisherPublishMessage message ) { handlePublisherPublishMessage ( request , message ) ; }
This method is thread - safe since we would push Messages into a Concurrent Queue .