From fdf44a4813b8d76f1baf72c960b4c85f498a8f39 Mon Sep 17 00:00:00 2001 From: Jean-Philippe Moal Date: Mon, 16 Oct 2023 12:33:51 +0200 Subject: [PATCH] fix: prevent backoff delay overflow --- consumer.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/consumer.go b/consumer.go index 8a31c15..df4e63b 100644 --- a/consumer.go +++ b/consumer.go @@ -941,11 +941,11 @@ func exponentialBackoff(min, max time.Duration, retry int) time.Duration { if retry > 0 { d = min << uint(retry-1) } + if (retry > 0 && d <= 0) || d > max { + return max + } if d < min { return min } - if d > max { - return max - } return d }