修复阻塞队列默认容量大小.

pull/12/head
chen.ma 3 years ago
parent 56c24058bc
commit b988b1a4e7

@ -125,11 +125,14 @@ public class ConfigServiceImpl implements ConfigService {
* @return * @return
*/ */
private Integer getQueueCapacityByType(ConfigAllInfo config) { private Integer getQueueCapacityByType(ConfigAllInfo config) {
int queueCapacity = 0; int queueCapacity;
switch (config.getQueueType()) { switch (config.getQueueType()) {
case 5: case 5:
queueCapacity = Integer.MAX_VALUE; queueCapacity = Integer.MAX_VALUE;
break; break;
default:
queueCapacity = config.getCapacity();
break;
} }
List<Integer> queueTypes = Stream.of(1, 2, 3, 6, 9).collect(Collectors.toList()); List<Integer> queueTypes = Stream.of(1, 2, 3, 6, 9).collect(Collectors.toList());

Loading…
Cancel
Save