requestObserver.onNext(CentralRequest.newBuilder()
.setHelloAck(HelloAck.getDefaultInstance())
.build());
}
startupLogger.info("downstream connection (re-)established with agent: {}",
<BUG>agentId);
return;</BUG>
}
long requestId = value.getRequestId();
ResponseHolder responseHolder = responseHolders.getIfPresent(requestId);

requestObserver.onNext(CentralRequest.newBuilder()
.setHelloAck(HelloAck.getDefaultInstance())
.build());
}
startupLogger.info("downstream connection (re-)established with agent: {}",
getAgentDisplay(agentId));
return;
}
if (agentId == null) {
logger.error("first message from agent to downstream service must be HELLO");
return;
}
long requestId = value.getRequestId();
ResponseHolder responseHolder = responseHolders.getIfPresent(requestId);
