1 write to ReplyQueue
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
179
Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).
ReplyQueue
= value!,
3 references to ReplyQueue
Aspire.Confluent.Kafka (3)
MetricsService.cs (1)
46
metrics.ReplyQueueMeasurements.Enqueue(new Measurement<long>(statistics.
ReplyQueue
, tags));
StatisticsJsonSerializerContext.Statistics.g.cs (2)
178
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
ReplyQueue
,
492
writer.WriteNumber(PropName_replyq, ((global::Aspire.Confluent.Kafka.Statistics)value).
ReplyQueue
);