nsq/caller.go @@ -42,6 +42,9 @@ case data := <-ReceivedMessageChan: if data.Topic == caller.ResponseTopic { return json.Unmarshal(data.Message, &output) } else { //把消息放回去 ReceivedMessageChan <- data } } }