通讯方式字段转换

zhangqian

2023-09-14 d93d2bc56ed06b3c060ff48f49591e8c5d779230

 nsq/caller.go

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

func (caller *DefaultCaller) Send(input interface{}) error {
   msg, err := json.Marshal(input)
   if err != nil {
      return err
   }
   producer := GetProducer()
   err = producer.Publish(caller.RequestTopic, msg)
   return err

}