From a4e829136aa40a34048d1686a397a7af88f4b7de Mon Sep 17 00:00:00 2001 From: Kailash Nadh Date: Tue, 6 Nov 2018 16:33:46 +0530 Subject: [PATCH] Log message push errors --- runner/runner.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/runner/runner.go b/runner/runner.go index a81c373..ea118fd 100644 --- a/runner/runner.go +++ b/runner/runner.go @@ -185,11 +185,14 @@ func (r *Runner) SpawnWorkers() { for { select { case m := <-ch: - r.messengers[m.Campaign.MessengerID].Push( + err := r.messengers[m.Campaign.MessengerID].Push( m.Campaign.FromEmail, m.Subscriber.Email, m.Campaign.Subject, m.Body) + if err != nil { + r.logger.Printf("error pushing message: %v", err) + } } } }(r.msgQueue)