in client/src/main/java/co/elastic/opamp/client/request/service/HttpRequestService.java [144:169]
private void doSendRequest() {
try {
Opamp.AgentToServer agentToServer = requestSupplier.get().getAgentToServer();
try (HttpSender.Response response =
requestSender
.send(
new ByteArrayWriter(agentToServer.toByteArray()),
agentToServer.getSerializedSize())
.get()) {
if (isSuccessful(response)) {
handleResponse(
Response.create(Opamp.ServerToAgent.parseFrom(response.bodyInputStream())));
} else {
handleHttpError(response);
}
} catch (IOException e) {
callback.onRequestFailed(e);
}
} catch (InterruptedException e) {
callback.onRequestFailed(e);
} catch (ExecutionException e) {
callback.onRequestFailed(e.getCause());
}
}