Commit 683ed56592bd7c7b3bcfbe2fef8e4208cada4f44
1 parent
5a057770
调整处理mq上限
- 调整处理mq上限
Showing
1 changed file
with
1 additions
and
1 deletions
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/CallHistoryTask.kt
... | ... | @@ -47,7 +47,7 @@ class CallHistoryTask( |
47 | 47 | fun dealCallHistory() { |
48 | 48 | val listOps = stringRedisTemplate.boundListOps(callReportKey) |
49 | 49 | val dataList = mutableListOf<String>() |
50 | - for (i in 0..100) { | |
50 | + for (i in 0..2000) { | |
51 | 51 | val dataStr = listOps.leftPop() |
52 | 52 | dataStr?.let { |
53 | 53 | dataList.add(dataStr) | ... | ... |