diff --git a/api/mq/base.go b/api/mq/base.go index 63759ec..8e0afa4 100644 --- a/api/mq/base.go +++ b/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(), diff --git a/api/mq/sku.go b/api/mq/sku.go deleted file mode 100644 index 26f853d..0000000 --- a/api/mq/sku.go +++ /dev/null @@ -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" -}