2 references to ReplyQueueMeasurements
Aspire.Confluent.Kafka (2)
ConfluentKafkaMetrics.cs (1)
87
while (
ReplyQueueMeasurements
.TryDequeue(out var measurement))
MetricsService.cs (1)
46
metrics.
ReplyQueueMeasurements
.Enqueue(new Measurement<long>(statistics.ReplyQueue, tags));