Compare commits
1 Commits
master
...
dev_local_
| Author | SHA1 | Date |
|---|---|---|
|
|
95479449f3 |
|
|
@ -50,6 +50,15 @@ public class RunOnlyHandler extends TextWebSocketHandler {
|
||||||
JSONObject msg = JSON.parseObject(payload);
|
JSONObject msg = JSON.parseObject(payload);
|
||||||
if (LOG_TYPE.equals(msg.getString(TYPE))) {
|
if (LOG_TYPE.equals(msg.getString(TYPE))) {
|
||||||
String runOnlyResultKey = RUN_ONLY_RESULT_KEY_PREFIX + msg.getString(DATA);
|
String runOnlyResultKey = RUN_ONLY_RESULT_KEY_PREFIX + msg.getString(DATA);
|
||||||
|
|
||||||
|
for (int i = 0; i < 20; i++) {
|
||||||
|
if (!redisHelper.hasKey(runOnlyResultKey)) {
|
||||||
|
ThreadUtil.sleepSilently(100);
|
||||||
|
} else {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
String runOnlyResult = redisHelper.get(runOnlyResultKey);
|
String runOnlyResult = redisHelper.get(runOnlyResultKey);
|
||||||
while (CASE_OUTPUT_SEPARATOR.equals(runOnlyResult) && redisHelper.hasKey(runOnlyResultKey)) {
|
while (CASE_OUTPUT_SEPARATOR.equals(runOnlyResult) && redisHelper.hasKey(runOnlyResultKey)) {
|
||||||
ThreadUtil.sleepSilently(100);
|
ThreadUtil.sleepSilently(100);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue