Skip to content

Commit 4c46038

Browse files
[ISSUE #9752] Fix time dequeue latency unit to milliseconds (#9753)
1 parent 3dd4bfd commit 4c46038

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ public void init(Meter meter, Supplier<AttributesBuilder> attributesBuilderSuppl
185185
.ofLongs()
186186
.buildWithCallback(measurement -> {
187187
TimerMessageStore timerMessageStore = messageStore.getTimerMessageStore();
188-
measurement.record(timerMessageStore.getDequeueBehind(), this.newAttributesBuilder().build());
188+
measurement.record(timerMessageStore.getDequeueBehindMillis(), this.newAttributesBuilder().build());
189189
});
190190
this.timingMessages = meter.gaugeBuilder(GAUGE_TIMING_MESSAGES)
191191
.setDescription("Current message number in timing")

0 commit comments

Comments
 (0)