in src/main/java/org/apache/pulsar/manager/utils/HttpUtil.java [160:193]
public String httpRequest(HttpUriRequest request, Map<String, String> header) {
CloseableHttpResponse response = null;
try {
for (Map.Entry<String, String> entry: header.entrySet()) {
request.setHeader(entry.getKey(), entry.getValue());
}
if (httpClient == null ) {
initHttpClient();
}
response = httpClient.execute(request);
if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
String strResult = EntityUtils.toString(response.getEntity());
response.close();
return strResult;
} else {
request.abort();
}
} catch (Throwable cause) {
log.error("http request exception message: {}, http request error stack: {}",
cause.getMessage(), cause.getCause());
} finally {
try{
if (response != null) {
response.close();
}
}catch (Exception e){
log.error("Don't handle exception: {}", e.getMessage());
}
}
return null;
}