Skip to content

Commit

Permalink
[fix][test] Make base test class method protected so that it passes R…
Browse files Browse the repository at this point in the history
…eportUnannotatedMethods validation (#21976)

(cherry picked from commit 67354b1)
  • Loading branch information
lhotari committed Jan 27, 2024
1 parent bca08d9 commit 0222d97
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -720,14 +720,14 @@ protected void sleepSeconds(int seconds){
}
}

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);
}

Expand Down

0 comments on commit 0222d97

Please sign in to comment.