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()