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