1.     public Mono<Object> getAuthScope(String token, Map<String, String> customHeaders) {
2.         LOGGER.debug("TokenService getAuthScope invoked with token : {} customHeaders {}", token, customHeaders);
3.        
4.         return webClient.get().uri(checkTokenEndpointUrl)
5.                         .header(AUTHORIZATION, getHeader())
6.                 .header(OAuth2AccessToken.ACCESS_TOKEN, token)
7.                 .header(REQUEST_URI, customHeaders.get(REQUEST_URI))
8.                 .exchange()
9.                 .doOnNext(handleResponse())
10.                 .doOnError(err -> {
11.                         LOGGER.error("Exception while validating token from rr auth gateway: " + err.getMessage());
12.                         throw new RuntimeException("Exception while validating token from rr auth gateway: "+err.getMessage());
13.                 }).flatMap(authScopeResponse -> authScopeResponse.bodyToMono(Object.class))
14.                 .log(LOGGER.getName(), Level.INFO, SignalType.ON_ERROR, SignalType.CANCEL)
15.                 .retryWhen(ioErrorRetry);
16.     }
17.    
18.     private Consumer<ClientResponse> handleResponse() {
19.         return response -> {
20.             if (Objects.nonNull(response)) {
21.                 HttpStatus status = response.statusCode();
22.                 if (status.is4xxClientError()) {
23.                     LOGGER.error(ERROR_MESSAGE_1, "4XX", status.value(), status.getReasonPhrase());
24.                     throw new BadCredentialsException("oAuth Token auth_scope GET Failed. Reason: access_token not found");
25.                 } else if (status.is5xxServerError()) {
26.                     LOGGER.error(ERROR_MESSAGE_1, "5XX", status.value(), status.getReasonPhrase());
27.                     throw new RuntimeException("oAuth Token auth_scope GET Failed");
28.                 }
29.             }
30.         };
31.     }