# 1.0.41

 修改消息推送

UPGRADE.md

+# 1.0.41
+- 修改消息推送
 # 1.0.40
 # 1.0.40
 - 商家退款账本接口增加 order_time字段 ByIds
 - 商家退款账本接口增加 order_time字段 ByIds
 # 1.0.39
 # 1.0.39

src/Cmq/Topic.php

@@ -255,13 +255,13 @@ class Topic
     	$tryTimes = 0;
     	$tryTimes = 0;
 
 
     	do{
     	do{
-		    $msgId = $this->publish_message($cryptMessage,$vTagList,$routingKey);
+		    $res = $this->publish_message($cryptMessage,$vTagList,$routingKey);
 		    $tryTimes++;
 		    $tryTimes++;
-	    }while(!$msgId || $tryTimes < 3);
+	    }while($res['code']!=0 && $tryTimes < 3);
 
 
     	if ($tryTimes > 3){
     	if ($tryTimes > 3){
     		App::error("[消息队列失败]:$message");
     		App::error("[消息队列失败]:$message");
 	    }
 	    }
-    	return $msgId;
+    	return $res;
     }
     }
 }
 }