Skip to content

Commit 59006b9

Browse files
author
hqbfzwang
committed
fix test
1 parent 893ee57 commit 59006b9

2 files changed

Lines changed: 4 additions & 6 deletions

File tree

pulsar-client/src/test/java/org/apache/pulsar/client/impl/metrics/ConsumerMetricsTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ public void testRecordNack() {
114114

115115
@Test
116116
public void testRecordDlq() {
117-
consumerMetrics.recordDlq();
117+
consumerMetrics.recordDlqMessageSent();
118118

119119
Collection<MetricData> metrics = metricReader.collectAllMetrics();
120120

pulsar-client/src/test/java/org/apache/pulsar/client/impl/metrics/ProducerMetricsTest.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -109,11 +109,9 @@ public void testRecordSendFailed() {
109109
}
110110

111111
@Test
112-
public void testRpcLatencyHistogramIsAccessible() {
113-
assertNotNull(producerMetrics.getRpcLatencyHistogram());
114-
115-
producerMetrics.getRpcLatencyHistogram().recordSuccess(TimeUnit.MILLISECONDS.toNanos(3));
116-
producerMetrics.getRpcLatencyHistogram().recordFailure(TimeUnit.MILLISECONDS.toNanos(1));
112+
public void testRpcLatency() {
113+
producerMetrics.recordRpcLatencySuccess(TimeUnit.MILLISECONDS.toNanos(3));
114+
producerMetrics.recordRpcLatencyFailure(TimeUnit.MILLISECONDS.toNanos(1));
117115

118116
Collection<MetricData> metrics = metricReader.collectAllMetrics();
119117
assertHistogramCount(metrics, "pulsar.client.producer.rpc.send.duration", 2);

0 commit comments

Comments
 (0)