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)