修改topic

config/config.go

@@ -22,6 +22,7 @@ type Config struct {
 	AccountId            uint   // 账号id
 	AccessKey            string // accessKey
 	SecretKey            string // secretKey
+	TopicPrefix          string // topic前缀
 	RefreshTokenCallback func(token *Bearer)
 }
 
@@ -33,6 +34,5 @@ type Bearer struct {
 	UID          string `json:"uid"`
 	Time         int64  `json:"time"`
 	TokenType    string `json:"token_type"`
-	Code         string `json:"code"`
 	Xid          string `json:"xid"`
 }

request/client.go

@@ -67,13 +67,13 @@ func exec(action string, data string, result interface{}) error {
 	respErr := RespErr{}
 	json.Unmarshal(bytes, &respErr)
 	if respErr.ErrorResponse.Code != "" {
-		if respErr.ErrorResponse.Code == "19" && config.SdkConfig.RefreshTokenCallback != nil {
+		//if respErr.ErrorResponse.Code == "19" && config.SdkConfig.RefreshTokenCallback != nil {
-			token, err := RefreshToken()
+		//	token, err := RefreshToken()
-			if err != nil {
+		//	if err != nil {
-				return err
+		//		return err
-			}
+		//	}
-			config.SdkConfig.RefreshTokenCallback(token)
+		//	config.SdkConfig.RefreshTokenCallback(token)
-		}
+		//}
 		return errors.New(respErr.ErrorResponse.ZhDesc)
 	}
 	mResp := map[string]resp{}
@@ -228,7 +228,7 @@ func (m *Message) ack(ackAction string) error {
 // ExecMq @Title 调用mq
 func ExecMq(action string) (Message, error) {
 	data := map[string]string{
-		"topic":           fmt.Sprintf("open_message_ct_%s_%s", action, config.SdkConfig.AppKey),
+		"topic":           fmt.Sprintf("%sopen_message_ct_%s_%s", config.SdkConfig.TopicPrefix, action, config.SdkConfig.AppKey),
 		"consumerGroupId": fmt.Sprintf("open_message_%d", config.SdkConfig.AccountId),
 	}
 	value := url.Values{}
@@ -291,6 +291,7 @@ func RefreshToken() (*config.Bearer, error) {
 	if err != nil {
 		return nil, err
 	}
+	log.Println(string(data))
 	var b config.Bearer
 	if err = json.Unmarshal(data, &b); err != nil {
 		return nil, err