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
 }