fix:mq使用https

api/mq/base.go

@@ -48,7 +48,7 @@ func getUTCStr() string {
 }
 
 func (c *Client) Pull(r UrlBase) ([]byte, error) {
-	mq := fmt.Sprintf("%s/%s/messages", http.FormatUrl(r.GetEndPoint(), false), "v2")
+	mq := fmt.Sprintf("%s/%s/messages", http.FormatUrl(r.GetEndPoint(), true), "v2")
 	value := url.Values{}
 	data := map[string]string{
 		PTopic:           r.GetTopicName(),

api/mq/sku.go

@@ -1,16 +0,0 @@
-package mq
-
-type CtSkuChangeChannel struct {
-}
-
-func (t CtSkuChangeChannel) GetTopicName() string {
-	return "open_message_ct_sku_change_7cf1b0ca92a1d3a2ccdbc07ce014a2c7"
-}
-
-func (t CtSkuChangeChannel) GetConsumerGroupID() string {
-	return "open_message_408486475484"
-}
-
-func (t CtSkuChangeChannel) GetEndPoint() string {
-	return "jcq-shared-004-httpsrv-nlb-FI.jvessel-open-hb.jdcloud.com:8080"
-}