return result;
}
- private synchronized void onStageResolved(final ShardBackendInfo result, final Throwable failure) {
+ private synchronized void onStageResolved(final ShardBackendInfo info, final Throwable failure) {
if (failure == null) {
- this.result = Preconditions.checkNotNull(result);
+ this.result = Preconditions.checkNotNull(info);
} else {
LOG.warn("Failed to resolve shard", failure);
}
LOG.debug("Shard {} resolved to {}, attempting to connect", shardName, info);
FutureConverters.toJava(ExplicitAsk.ask(info.getPrimaryShardActor(), connectFunction, CONNECT_TIMEOUT))
- .whenComplete((response, failure) -> {
- onConnectResponse(shardName, cookie, future, response, failure);
- });
+ .whenComplete((response, failure) -> onConnectResponse(shardName, cookie, future, response, failure));
}
private void onConnectResponse(final String shardName, final long cookie,