Skip to content

Commit 2b1c35f

Browse files
committed
fix race condition?
1 parent c45083a commit 2b1c35f

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
<packaging>jar</packaging>
2929
<name>Metrics Cluster Aggregator</name>
3030
<description>(Re)Aggregates host level statistics across clusters and writes both host and cluster statistics to various destinations.</description>
31-
<version>1.12.2-SNAPSHOT</version>
31+
<version>1.12.2</version>
3232

3333
<licenses>
3434
<license>
@@ -96,7 +96,7 @@
9696
<connection>scm:git:[email protected]:ArpNetworking/metrics-cluster-aggregator.git</connection>
9797
<developerConnection>scm:git:[email protected]:ArpNetworking/metrics-cluster-aggregator.git</developerConnection>
9898
<url>https://github.com/arpnetworking/metrics-cluster-aggregator</url>
99-
<tag>HEAD</tag>
99+
<tag>metrics-cluster-aggregator-1.12.2</tag>
100100
</scm>
101101

102102
<properties>

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -428,8 +428,8 @@ private void fireRequest(final RequestEntry request, final int attempt) {
428428
return new PostFailure(attempt, request, err);
429429
}
430430
});
431-
_client.executeRequest(request.getRequest(), new ResponseAsyncCompletionHandler(promise));
432431
Patterns.pipe(responsePromise, context().dispatcher()).to(self());
432+
_client.executeRequest(request.getRequest(), new ResponseAsyncCompletionHandler(promise));
433433
}
434434

435435
private void scheduleRetry(final RequestEntry requestEntry, final int attempt) {

0 commit comments

Comments
 (0)