Merge pull request #14 from czeslavo/master

Make exponential backoff in subscriber not expiring
ThreeDotsLabs · Jun 7, 2021 · 7463808 · 7463808
2 parents 2d39aa7 + f033cee
commit 7463808
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/googlecloud/subscriber.go b/pkg/googlecloud/subscriber.go
@@ -174,6 +174,9 @@ func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *messa
 	receiveFinished := make(chan struct{})
 	s.allSubscriptionsWaitGroup.Add(1)
 	go func() {
+		exponentialBackoff := backoff.NewExponentialBackOff()
+		exponentialBackoff.MaxElapsedTime = 0 // 0 means it never expires
+
 		if err := backoff.Retry(func() error {
 			err := s.receive(ctx, sub, logFields, output)
 			if err == nil {
@@ -188,7 +191,7 @@ func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *messa
 
 			s.logger.Error("Receiving messages failed, retrying", err, logFields)
 			return err
-		}, backoff.NewExponentialBackOff()); err != nil {
+		}, exponentialBackoff); err != nil {
 			s.logger.Error("Retrying receiving messages failed", err, logFields)
 		}