通讯方式字段转换

zhangqian

2023-09-14 d93d2bc56ed06b3c060ff48f49591e8c5d779230

 nsq/caller.go

@@ -49,3 +49,14 @@
      }
   }
}

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

}