✨ Send retries before new messages

redBorder · Oct 18, 2016 · c6467e3 · c6467e3
1 parent b9a285b
commit c6467e3
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/pipeline.go b/pipeline.go
@@ -88,6 +88,19 @@ func (p *pipeline) Run() {
 					worker := <-p.components[rep.Component].pool
 					worker <- m
 				}
+				continue
+
+			default:
+			}
+
+			select {
+			case m, ok := <-p.retry:
+				if ok {
+					rep := m.Reports.Head().(Report)
+					worker := <-p.components[rep.Component].pool
+					worker <- m
+				}
+				continue
 
 			case m, ok := <-p.input:
 				// If input channel has been closed, close output channel