From 98f14ba0a9c8a7aea519c692e8e7dd5476871d6d Mon Sep 17 00:00:00 2001
From: wqliang <wqliang98@gmail.com>
Date: Fri, 8 May 2020 11:29:34 +0800
Subject: [PATCH] fix potential overflow and limit upper bound

---
 .../webank/defibus/broker/client/AdjustQueueNumStrategy.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java b/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java
index da9b5c34a..36bf8f391 100644
--- a/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java
+++ b/defibus-broker/src/main/java/cn/webank/defibus/broker/client/AdjustQueueNumStrategy.java
@@ -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;
         }