From f15510acf70d937e495ff4c925013df4dd9589ae Mon Sep 17 00:00:00 2001 From: kanade Date: Tue, 18 Oct 2022 13:45:48 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=AE=A2=E9=98=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- supply/channel/mq.go | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/supply/channel/mq.go b/supply/channel/mq.go index 608b7b9..48e62d0 100644 --- a/supply/channel/mq.go +++ b/supply/channel/mq.go @@ -7,13 +7,12 @@ import ( ) const ( - MqSubscribeNameSkuPriceChange = "sku_price_change" // sku价格变动 - MqSubscribeNameSkuChange = "sku_change" // sku信息变动 - MqSubscribeNameOrderSplit = "order_split" // 订单拆单 - MqSubscribeNameOrderLadingBill = "order_lading_bill" // 提单 - MqSubscribeNameOrderStockOut = "order_stock_out" // 订单出库 - MqSubscribeNameOrderFinish = "order_finish" // 订单完成 - MqSubscribeNameOrderCancel = "order_cancel" // 订单取消 + MqSubscribeNameSkuPriceChange = "sku_price_change" // sku价格变动 + MqSubscribeNameSkuChange = "sku_change" // sku信息变动 + MqSubscribeNameOrderSplit = "order_split" // 订单拆单 + MqSubscribeNameOrderStockOut = "order_stock_out" // 订单出库 + MqSubscribeNameOrderFinish = "order_finish" // 订单完成 + MqSubscribeNameOrderCancel = "order_cancel" // 订单取消 ) type mq struct { @@ -24,13 +23,12 @@ type ArgsMqSubscribe struct { } // Subscribe @Title 订阅mq -func (m *mq) Subscribe(ctx context.Context, channelId string, args ArgsMqSubscribe) (err error) { - reply := 0 +func (m *mq) Subscribe(ctx context.Context, channelId string, args ArgsMqSubscribe) (key string, err error) { xClient, err := client.GetClient(m) if err != nil { return } - err = xClient.Call(context.WithValue(ctx, share.ReqMetaDataKey, map[string]string{"channelId": channelId}), "Subscribe", args, &reply) + err = xClient.Call(context.WithValue(ctx, share.ReqMetaDataKey, map[string]string{"channelId": channelId}), "Subscribe", args, &key) return }