fix test

Author: hqbfzwang

pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java

@@ -182,7 +182,6 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne
     private boolean errorState;
 
     private final ProducerMetrics producerMetrics;
-    // rpcLatencyHistogram 需要传递给 OpSendMsg，保留包级别访问
     final LatencyHistogram rpcLatencyHistogram;
     private final boolean pauseSendingToPreservePublishOrderOnSchemaRegFailure;
     // This variable can be exposed as a metrics in the future, a PIP is needed.
@@ -288,7 +287,7 @@ public ProducerImpl(PulsarClientImpl client, String topic, ProducerConfiguration
 
         InstrumentProvider ip = client.instrumentProvider();
         producerMetrics = new ProducerMetrics(ip, topic);
-        rpcLatencyHistogram = producerMetrics.rpcLatencyHistogram;
+        rpcLatencyHistogram = producerMetrics.getRpcLatencyHistogram();
         pendingQueueFullCounter = new AtomicInteger();
 
         this.connectionHandler = initConnectionHandler();

pulsar-client/src/main/java/org/apache/pulsar/client/impl/metrics/ProducerMetrics.java

@@ -23,7 +23,7 @@
 public class ProducerMetrics {
 
     private final LatencyHistogram sendLatencyHistogram;
-    public final LatencyHistogram rpcLatencyHistogram;
+    private final LatencyHistogram rpcLatencyHistogram;
     private final Counter publishedBytesCounter;
     private final UpDownCounter pendingMessagesUpDownCounter;
     private final UpDownCounter pendingBytesUpDownCounter;
@@ -92,4 +92,8 @@ public void recordProducerOpened() {
     public void recordProducerClosed() {
         producersClosedCounter.increment();
     }
+
+    public LatencyHistogram getRpcLatencyHistogram() {
+        return rpcLatencyHistogram;
+    }
 }

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

@@ -110,10 +110,10 @@ public void testRecordSendFailed() {
 
     @Test
     public void testRpcLatencyHistogramIsAccessible() {
-        assertNotNull(producerMetrics.rpcLatencyHistogram);
+        assertNotNull(producerMetrics.getRpcLatencyHistogram());
 
-        producerMetrics.rpcLatencyHistogram.recordSuccess(TimeUnit.MILLISECONDS.toNanos(3));
-        producerMetrics.rpcLatencyHistogram.recordFailure(TimeUnit.MILLISECONDS.toNanos(1));
+        producerMetrics.getRpcLatencyHistogram().recordSuccess(TimeUnit.MILLISECONDS.toNanos(3));
+        producerMetrics.getRpcLatencyHistogram().recordFailure(TimeUnit.MILLISECONDS.toNanos(1));
 
         Collection<MetricData> metrics = metricReader.collectAllMetrics();
         assertHistogramCount(metrics, "pulsar.client.producer.rpc.send.duration", 2);