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

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


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

commit 855050880c17461cc34e714ec7806489dcda4718
Author: Lari Hotari <lhot...@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 f298a58b764..2fd3436b4a2 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
@@ -715,14 +715,14 @@ public abstract class MockedPulsarServiceBaseTest extends 
TestRetrySupport {
         private PersistentTopic persistentTopic;
     }
 
-    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);
     }
 

Reply via email to