diff options
| author | Ivan Topolnjak <ivantopo@gmail.com> | 2018-11-30 14:33:58 +0100 |
|---|---|---|
| committer | Ivan Topolnjak <ivantopo@gmail.com> | 2019-01-06 12:36:58 +0100 |
| commit | e311df4b3a272f4f160857f718a96ec316a2fc06 (patch) | |
| tree | 38d0a7b657d8332d039a5a637bd18276e92248b3 | |
| parent | 55e052f0da580296c9b273612c50c57f8ad4206d (diff) | |
| download | Kamon-e311df4b3a272f4f160857f718a96ec316a2fc06.tar.gz Kamon-e311df4b3a272f4f160857f718a96ec316a2fc06.tar.bz2 Kamon-e311df4b3a272f4f160857f718a96ec316a2fc06.zip | |
clean references to scheduled range sampler collections
| -rw-r--r-- | kamon-core/src/main/scala/kamon/metric/Metric.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/Metric.scala b/kamon-core/src/main/scala/kamon/metric/Metric.scala index f63e3d07..a66d1229 100644 --- a/kamon-core/src/main/scala/kamon/metric/Metric.scala +++ b/kamon-core/src/main/scala/kamon/metric/Metric.scala @@ -162,7 +162,7 @@ private[kamon] final class RangeSamplerMetricImpl(val name: String, val unit: Me private def removeAndStopSampler(tags: Tags): Boolean = { val removed = super.remove(tags) if(removed) - scheduledSamplers.get(tags).foreach(sf => { + scheduledSamplers.remove(tags).foreach(sf => { Try(sf.cancel(false)).failed.foreach(_ => logger.error("Failed to cancel scheduled sampling for RangeSampler []", tags.prettyPrint())) }) removed |