Skip to content

Commit c45083a

Browse files
committed
fix possible race condition
1 parent 23163fb commit c45083a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/arpnetworking/tsdcore/sinks/HttpSinkActor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,6 @@ private void fireNextRequest() {
412412
private void fireRequest(final RequestEntry request, final int attempt) {
413413
final CompletableFuture<Response> promise = new CompletableFuture<>();
414414
final long requestStartTime = System.currentTimeMillis();
415-
_client.executeRequest(request.getRequest(), new ResponseAsyncCompletionHandler(promise));
416415
final CompletionStage<Object> responsePromise = promise
417416
.handle((result, err) -> {
418417
_periodicMetrics.recordTimer(
@@ -429,6 +428,7 @@ private void fireRequest(final RequestEntry request, final int attempt) {
429428
return new PostFailure(attempt, request, err);
430429
}
431430
});
431+
_client.executeRequest(request.getRequest(), new ResponseAsyncCompletionHandler(promise));
432432
Patterns.pipe(responsePromise, context().dispatcher()).to(self());
433433
}
434434

0 commit comments

Comments
 (0)