You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/01/27 07:44:50 UTC

(pulsar) branch branch-3.2 updated: [fix][test] Make base test class method protected so that it passes ReportUnannotatedMethods validation (#21976)

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.2 by this push:
     new 0222d970a82 [fix][test] Make base test class method protected so that it passes ReportUnannotatedMethods validation (#21976)
0222d970a82 is described below

commit 0222d970a8233bc070ac54e3ad874ebd019640e9
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Fri Jan 26 23:40:39 2024 -0800

    [fix][test] Make base test class method protected so that it passes ReportUnannotatedMethods validation (#21976)
    
    (cherry picked from commit 67354b15650b7d0bfa92f4ad92effcf5c6a1ca72)
---
 .../org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java
index 0e9c09d0802..bd08ced1e03 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/auth/MockedPulsarServiceBaseTest.java
@@ -720,14 +720,14 @@ public abstract class MockedPulsarServiceBaseTest extends TestRetrySupport {
         }
     }
 
-    public static void reconnectAllConnections(PulsarClientImpl c) throws Exception {
+    private static void reconnectAllConnections(PulsarClientImpl c) throws Exception {
         ConnectionPool pool = c.getCnxPool();
         Method closeAllConnections = ConnectionPool.class.getDeclaredMethod("closeAllConnections", new Class[]{});
         closeAllConnections.setAccessible(true);
         closeAllConnections.invoke(pool, new Object[]{});
     }
 
-    public void reconnectAllConnections() throws Exception {
+    protected void reconnectAllConnections() throws Exception {
         reconnectAllConnections((PulsarClientImpl) pulsarClient);
     }