fix #14

broker/dispatcher.go

@@ -34,10 +34,8 @@ func (d *Dispatcher) dispatch() {
 			for {
 				select {
 				case msg := <-MSGPool[idx].queue:
-					go func(msg *Message) {
 					msgChannel := <-d.WorkerPool
 					msgChannel <- msg
-					}(msg)
 				}
 			}
 		}(i)