fix

zhangqian

2023-10-30 10c65da3d2af7056f48d9301e83f53f102f76e18

 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)