in gemini/src/main/java/deltix/connector/crypto/gemini/GeminiHttpClient.java [79:96]
public void sendHeartbeat() {
final DefaultRequest request = new DefaultRequest();
request.setRequest("/v1/heartbeat");
request.setNonce(context.getApiKeyContext().nextNonce());
final RequestBuilder requestBuilder = createRequestBuilder(heartbeatUrl, "Heartbeat", request);
context.getHttpClient().executeRequest(requestBuilder)
.toCompletableFuture()
.handle((BiFunction<Response, Throwable, Void>) (response, throwable) -> {
if (throwable != null) {
getLog().error("Heartbeat submission failed: %s").with(throwable);
} else if (response.getStatusCode() != HttpConstants.ResponseStatusCodes.OK_200) {
getLog().error("Heartbeat submission failed: %s").with(response.getResponseBody());
}
return null;
});
}