zhangqian
2023-09-17 181733a7142ee4de79061f7e5796f9cdb21fc7d8
nsq/caller.go
@@ -1,8 +1,9 @@
package nsq
import (
   "apsClient/pkg/logx"
   "encoding/json"
   "errors"
   "fmt"
   "time"
)
@@ -38,7 +39,8 @@
   for {
      select {
      case <-to:
         return errors.New("timeout")
         logx.Errorf("message call failed due to timeout, request topic: %v, msg: %+v, responseTopic", caller.RequestTopic, input, caller.ResponseTopic)
         return fmt.Errorf("wait response message timeout when request: %v", caller.ResponseTopic)
      case data := <-ReceivedMessageChan:
         if data.Topic == caller.ResponseTopic {
            return json.Unmarshal(data.Message, &output)