wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-2481: remove access

Browse Source
This commit is contained in:
yanglin 2024-06-03 16:22:35 +08:00
parent c80b673203
commit 9ac1629540
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
im-center-server/src/main/java/cn/axzo/im/send/ScanAndSendService.java
View File

@ -80,7 +80,7 @@ public class ScanAndSendService {
drainLogs(logQueue);
break;
} catch (TimeoutException e) {
consumeLogs(logQueue);
drainLogs(logQueue);
}
}
} catch (InterruptedException e) {
@ -124,15 +124,6 @@ public class ScanAndSendService {
}
}
private void consumeLogs(BlockingQueue<String> logQueue) throws InterruptedException {
for (int i = 0; i < 500; i++) {
String message = logQueue.poll();
if (message == null)
break;
log.info(message);
}
}
private SendJobInfo trySaveSendJobInfo(int estimatedCount) {
String logFile = XxlJobFileAppender.contextHolder.get();
if (!StringUtils.isNotBlank(logFile))