liaodn opened a new issue, #174:
URL: https://github.com/apache/bifromq/issues/174
Mqtt.tsub.latency looks like it's a statistical measure of the latency of
cleanSession is true message subscriptions
But the location where the relevant code was written may be incorrect, Now
written in the MQTTSessionHandler class,
`Timer.Sample start = Timer.start();
return addFgTask(subTopicFilter(reqId, topicFilter,
tfOption))
.thenComposeAsync(subResult -> {
switch (subResult) {
case OK, EXISTS -> {
start.stop(tenantMeter.timer(MqttTransientSubLatency));
if
(!isSharedSubscription(topicFilter) && settings.retainEnabled
&& (tfOption.getRetainHandling()
== SEND_AT_SUBSCRIBE
|| (subResult ==
IMQTTProtocolHelper.SubResult.OK`
it seems that it needs to be written in the MQTTransientSessionHandler class
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr...@bifromq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
