@@ -65,8 +65,8 @@ public MetricsReporter(IMeterFactory meterFactory)
6565
6666 _publishDuration = meter . CreateHistogram < double > (
6767 MetricPrefix + ".published.duration" ,
68- unit : "ms " ,
69- description : "Elapsed time between publishing a message and receiving a broker response, in milliseconds ." ) ;
68+ unit : "s " ,
69+ description : "Elapsed time between publishing a message and receiving a broker response, in seconds ." ) ;
7070
7171 _publishAccepted = meter . CreateCounter < int > (
7272 MetricPrefix + ".published_accepted" ,
@@ -90,8 +90,8 @@ public MetricsReporter(IMeterFactory meterFactory)
9090
9191 _consumedDuration = meter . CreateHistogram < double > (
9292 MetricPrefix + ".consumed.duration" ,
93- unit : "ms " ,
94- description : "Elapsed time of receiving a message and handling it, in milliseconds ." ) ;
93+ unit : "s " ,
94+ description : "Elapsed time of receiving a message and handling it, in seconds ." ) ;
9595
9696 _consumeAccepted = meter . CreateCounter < int > (
9797 MetricPrefix + ".consumed_accepted" ,
@@ -142,7 +142,7 @@ public void ConsumerClosed()
142142 public void Published ( TimeSpan elapsed )
143143 {
144144 _published . Add ( 1 ) ;
145- _publishDuration . Record ( elapsed . TotalMilliseconds ) ;
145+ _publishDuration . Record ( elapsed . TotalSeconds ) ;
146146 }
147147
148148 public void PublishDisposition ( IMetricsReporter . PublishDispositionValue disposition )
@@ -164,7 +164,7 @@ public void PublishDisposition(IMetricsReporter.PublishDispositionValue disposit
164164 public void Consumed ( TimeSpan elapsed )
165165 {
166166 _consumed . Add ( 1 ) ;
167- _consumedDuration . Record ( elapsed . TotalMilliseconds ) ;
167+ _consumedDuration . Record ( elapsed . TotalSeconds ) ;
168168 }
169169
170170 public void ConsumeDisposition ( IMetricsReporter . ConsumeDispositionValue disposition )
0 commit comments