apache
/
eventmesh
4
0
Fork 1
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Merge pull request #17 from wqliang/fixPotentialOverflow 

fix potential overflow and limit upper bound
This commit is contained in:
Eason Chen 2020-05-08 14:17:30 +08:00 committed by GitHub
parent 80c00cdc14 98f14ba0a9
commit 437c2a38c0
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java
View File

@ -84,7 +84,8 @@ public class AdjustQueueNumStrategy {
case DECREASE_QUEUE_NUM:
adjustWriteQueueNumByConsumerCount(topic, 0, scaleType);
long delayTimeMillis = deFiBrokerController.getDeFiBusBrokerConfig().getScaleQueueSizeDelayTimeMinute() * 60 * 1000;
long delayTimeMinutes = Math.min(deFiBrokerController.getDeFiBusBrokerConfig().getScaleQueueSizeDelayTimeMinute(), 10);
long delayTimeMillis = delayTimeMinutes * 60 * 1000;
adjustReadQueueNumByConsumerCount(topic, delayTimeMillis, scaleType);
break;
}