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