From fc45b6f1ffbeaebeb551060d10b50f9f78e434e9 Mon Sep 17 00:00:00 2001 From: Michael Marshall Date: Mon, 23 Jan 2023 15:08:46 -0600 Subject: [PATCH] [improve][broker] Replace authenticate with authenticateAsync --- .../pulsar/broker/authentication/AuthenticationProvider.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java index f150a084237f5..f51e96ca9a779 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java @@ -156,7 +156,7 @@ default CompletableFuture authenticateHttpRequestAsync(HttpServletReque @Deprecated default boolean authenticateHttpRequest(HttpServletRequest request, HttpServletResponse response) throws Exception { AuthenticationState authenticationState = newHttpAuthState(request); - String role = authenticate(authenticationState.getAuthDataSource()); + String role = authenticateAsync(authenticationState.getAuthDataSource()).get(); request.setAttribute(AuthenticatedRoleAttributeName, role); request.setAttribute(AuthenticatedDataAttributeName, authenticationState.getAuthDataSource()); return true;