diff options
Diffstat (limited to 'kamon-core/src/main/scala/kamon/ReporterRegistry.scala')
| -rw-r--r-- | kamon-core/src/main/scala/kamon/ReporterRegistry.scala | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/kamon-core/src/main/scala/kamon/ReporterRegistry.scala b/kamon-core/src/main/scala/kamon/ReporterRegistry.scala index e18b6a78..6c8622d4 100644 --- a/kamon-core/src/main/scala/kamon/ReporterRegistry.scala +++ b/kamon-core/src/main/scala/kamon/ReporterRegistry.scala @@ -120,11 +120,14 @@ class ReporterRegistryImpl(metrics: MetricsSnapshotGenerator, initialConfig: Con executionContext = ExecutionContext.fromExecutorService(executor) ) + Future(reporterEntry.reporter.start())(reporterEntry.executionContext) + if(metricReporters.isEmpty) reStartMetricTicker() metricReporters.put(reporterEntry.id, reporterEntry) createRegistration(reporterEntry.id, metricReporters) + } private def addSpanReporter(reporter: SpanReporter, name: String): Registration = synchronized { @@ -136,6 +139,8 @@ class ReporterRegistryImpl(metrics: MetricsSnapshotGenerator, initialConfig: Con executionContext = ExecutionContext.fromExecutorService(executor) ) + Future(reporterEntry.reporter.start())(reporterEntry.executionContext) + if(spanReporters.isEmpty) reStartTraceTicker() |