Revert "handle overflow"

This reverts commit dba0661.
Azure · Oct 24, 2023 · bd6bd1d · bd6bd1d
1 parent 2e0be9b
commit bd6bd1d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 15 deletions.
diff --git a/...bus/Microsoft.Azure.WebJobs.Extensions.ServiceBus/src/Listeners/ServiceBusTargetScaler.cs b/...bus/Microsoft.Azure.WebJobs.Extensions.ServiceBus/src/Listeners/ServiceBusTargetScaler.cs
@@ -94,17 +94,7 @@ internal TargetScalerResult GetScaleResultInternal(TargetScalerContext context,
                 throw new ArgumentOutOfRangeException($"Unexpected concurrency='{concurrency}' - the value must be > 0.");
             }
 
-            int targetWorkerCount;
-
-            try
-            {
-                targetWorkerCount = (int)Math.Ceiling(messageCount / (decimal)concurrency);
-            }
-            catch (OverflowException)
-            {
-                targetWorkerCount = int.MaxValue;
-            }
-
+            int targetWorkerCount = (int)Math.Ceiling(messageCount / (decimal)concurrency);
             _logger.LogInformation($"Target worker count for function '{_functionId}' is '{targetWorkerCount}' (EntityPath='{_entityPath}', MessageCount ='{messageCount}', Concurrency='{concurrency}').");
 
             return new TargetScalerResult

diff --git a/...rosoft.Azure.WebJobs.Extensions.ServiceBus/tests/Listeners/ServiceBusTargetScalerTests.cs b/...rosoft.Azure.WebJobs.Extensions.ServiceBus/tests/Listeners/ServiceBusTargetScalerTests.cs
@@ -27,10 +27,7 @@ public void Setup()
         [TestCase(100, true, true, null, 4)]
         [TestCase(100, false, true, 19, 6)]
         [TestCase(100, false, false, null, 3)]
-        [TestCase(100, false, false, null, 3)]
-        [TestCase(2147483650, false, false, 1, 2147483647)] // cap targetWorkerCount at int.MaxValue
-        [TestCase(2147483650, false, false, 2, 1073741825)]
-        public void ServiceBusTargetScaler_Returns_Expected(long messageCount, bool isSessionEnabled, bool singleDispatch, int? concurrency, int expected)
+        public void ServiceBusTargetScaler_Returns_Expected(int messageCount, bool isSessionEnabled, bool singleDispatch, int? concurrency,int expected)
         {
             ServiceBusOptions options = new ServiceBusOptions
             {