From 6491f46955e6979a34b0993a4e2c38c9053e1902 Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Wed, 25 Dec 2019 20:04:29 -0800 Subject: [PATCH] Minor cleanup --- processor.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/processor.go b/processor.go index b4a7139..f2076b0 100644 --- a/processor.go +++ b/processor.go @@ -137,13 +137,12 @@ func (p *processor) exec() { if resErr != nil { if msg.Retried >= msg.Retry { p.kill(msg, resErr.Error()) - return + } else { + p.retry(msg, resErr.Error()) } - p.retry(msg, resErr.Error()) return } p.markAsDone(msg) - return } }() }