|
17 | 17 |
|
18 | 18 | import static com.rabbitmq.perf.metrics.MetricsFormatterUtils.MESSAGE_RATE_LABEL; |
19 | 19 | import static com.rabbitmq.perf.metrics.MetricsFormatterUtils.formatRate; |
20 | | -import static com.rabbitmq.perf.metrics.MetricsFormatterUtils.formatTime; |
21 | 20 | import static java.lang.String.format; |
22 | 21 | import static java.util.concurrent.TimeUnit.MILLISECONDS; |
23 | 22 | import static java.util.concurrent.TimeUnit.NANOSECONDS; |
24 | 23 |
|
25 | 24 | import java.io.PrintStream; |
26 | 25 | import java.time.Duration; |
| 26 | +import java.time.LocalDateTime; |
| 27 | +import java.time.format.DateTimeFormatter; |
27 | 28 | import java.util.concurrent.TimeUnit; |
28 | 29 |
|
29 | 30 | class CompactPrintStreamMetricsFormatter extends BaseMetricsFormatter implements MetricsFormatter { |
30 | 31 |
|
31 | | - // e.g. 99999.999s |
32 | | - private static final String TIME_FORMAT = "%-10s"; |
| 32 | + private static final String DATE_TIME_FORMAT = "yyyy/MM/dd HH:mm:ss"; |
| 33 | + private static final DateTimeFormatter DATE_TIME_FORMATTER = |
| 34 | + DateTimeFormatter.ofPattern(DATE_TIME_FORMAT); |
| 35 | + |
| 36 | + // e.g. 2025/04/08 16:54:19 |
| 37 | + private static final String TIME_FORMAT = "%-" + DATE_TIME_FORMAT.length() + "s"; |
33 | 38 | // up to 999999 (6), space (1), msg/s (5), leading space to separate (1) |
34 | 39 | private static final String RATE_FORMAT = "%13s"; |
35 | 40 | // 6 values of 3 digits, 5 separators, 1 space, 2 characters for unit, 1 space to separate |
@@ -97,7 +102,7 @@ public void report( |
97 | 102 | long[] confirmedLatencyStats, |
98 | 103 | long[] consumerLatencyStats) { |
99 | 104 | StringBuilder builder = |
100 | | - new StringBuilder().append(format(TIME_FORMAT, formatTime(durationSinceStart) + "s")); |
| 105 | + new StringBuilder().append(DATE_TIME_FORMATTER.format(LocalDateTime.now())); |
101 | 106 | if (this.publishedEnabled) { |
102 | 107 | builder.append(format(RATE_FORMAT, formatRate(publishedRate) + " " + MESSAGE_RATE_LABEL)); |
103 | 108 | } |
|
0 commit comments