fix consumer doesn't consume message because of blocked on Lock in so…

…me case

consumer/process_queue.go

@@ -104,6 +104,7 @@ func (pq *processQueue) putMessage(messages ...*primitive.MessageExt) {
 	if !pq.order {
 		select {
 		case <-pq.closeChan:
+			pq.mutex.Unlock()
 			return
 		case pq.msgCh <- messages:
 		}