From 3e49972e05a67e3c17b229af39b3f4b648132cf7 Mon Sep 17 00:00:00 2001 From: Umputun Date: Wed, 14 Nov 2018 11:05:37 -0600 Subject: [PATCH] revert multiple attempt to notify, may cause dbl-posting --- backend/app/notify/notify.go | 17 ++++------------- 1 file changed, 4 insertions(+), 13 deletions(-) diff --git a/backend/app/notify/notify.go b/backend/app/notify/notify.go index d9b8268b..f8f75859 100644 --- a/backend/app/notify/notify.go +++ b/backend/app/notify/notify.go @@ -8,9 +8,6 @@ import ( "sync" "sync/atomic" - "github.com/go-pkgz/repeater" - "github.com/go-pkgz/repeater/strategy" - "github.com/umputun/remark/backend/app/store" "github.com/umputun/remark/backend/app/store/service" ) @@ -94,16 +91,10 @@ func (s *Service) do() { 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) - }) - if err != nil { - log.Printf("[WARN] failed to send to %s, %s", d, err) - } - wg.Done() - }(dest) + if err := dest.Send(s.ctx, c); err != nil { + log.Printf("[WARN] failed to send to %s, %s", dest, err) + } + wg.Done() } wg.Wait() }