From 7719533962ba43afaccb8272b33a12317e2634f2 Mon Sep 17 00:00:00 2001
From: Louis Poinsignon <louis@cloudflare.com>
Date: Mon, 30 Sep 2019 15:11:02 -0700
Subject: [PATCH] Fix for #40: change the position of the channel

---
 decoders/decoder.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/decoders/decoder.go b/decoders/decoder.go
index edfb1b8..8eebaf3 100644
--- a/decoders/decoder.go
+++ b/decoders/decoder.go
@@ -39,11 +39,11 @@ func (w Worker) Start() {
 	go func() {
 		//log.Debugf("Worker %v started", w.Id)
 		for {
-			w.WorkerPool <- w.InMsg
 			select {
 			case <-w.Quit:
 				break
-			case msg := <-w.InMsg:
+			case w.WorkerPool <- w.InMsg:
+				msg := <-w.InMsg
 				timeTrackStart := time.Now()
 				err := w.DecoderParams.DecoderFunc(msg)
 				timeTrackStop := time.Now()