From cbb534d2df7f97c3886568e5513024d5e71445a0 Mon Sep 17 00:00:00 2001 From: Umputun Date: Mon, 12 Nov 2018 02:10:22 -0600 Subject: [PATCH] init repeater in send loop --- backend/app/notify/notify.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/app/notify/notify.go b/backend/app/notify/notify.go index 14b2c6b1..bdec6404 100644 --- a/backend/app/notify/notify.go +++ b/backend/app/notify/notify.go @@ -89,11 +89,11 @@ func (s *Service) Close() { } func (s *Service) do() { - rpt := repeater.New(strategy.NewBackoff(5, 1.5, true)) for c := range s.queue { var wg sync.WaitGroup for _, dest := range s.destinations { wg.Add(1) + rpt := repeater.New(strategy.NewBackoff(5, 1.5, true)) go func(d Destination) { err := rpt.Do(func() error { return d.Send(s.ctx, c)