in java/e2e-v4/src/main/java/org/apache/rocketmq/client/callback/RMQSendCallBack.java [54:59]
public void waitResponse() {
long start = System.currentTimeMillis();
while (System.currentTimeMillis() - start < WAIT_RESPONSE_MILLS && (!bSuccessResponse && !bFailResponse)) {
TestUtils.waitForMoment(100);
}
}