add comments.

Author: freyhsiao

src/Queue/CMQQueue.php

@@ -40,6 +40,13 @@ class CMQQueue extends Queue implements QueueContract
      */
     private static $createPayload;
 
+    /**
+     * CMQQueue constructor.
+     * @param Account $queueAccount
+     * @param Account $topicAccount
+     * @param array $config
+     * @throws \ReflectionException
+     */
     public function __construct(Account $queueAccount, Account $topicAccount, array $config)
     {
         $this->queueAccount = $queueAccount;
@@ -129,12 +136,12 @@ public function pushRaw($payload, $queue = null, array $options = [])
         if ($driver instanceof Topic) {
             switch ($this->topicOptions['filter']) {
                 case self::CMQ_TOPIC_TAG_FILTER_NAME:
-                    return retry(Arr::get($this->topicOptions, 'retries', 1),
+                    return retry(Arr::get($this->topicOptions, 'retries', 3),
                         function () use ($driver, $message, $queue) {
                             return $driver->publish_message($message->msgBody, explode(',', $queue), null);
                         });
                 case self::CMQ_TOPIC_ROUTING_FILTER_NAME:
-                    return retry(Arr::get($this->topicOptions, 'retries', 1),
+                    return retry(Arr::get($this->topicOptions, 'retries', 3),
                         function () use ($driver, $message, $queue) {
                             $driver->publish_message($message->msgBody, [], $queue);
                         });
@@ -145,7 +152,7 @@ function () use ($driver, $message, $queue) {
             }
         }
 
-        return retry(Arr::get($this->queueOptions, 'retries', 1), function () use ($driver, $message, $options) {
+        return retry(Arr::get($this->queueOptions, 'retries', 3), function () use ($driver, $message, $options) {
             return $driver->send_message($message, Arr::get($options, 'delay', 0));
         });
     }

tests/CMQQueueTest.php

@@ -29,14 +29,14 @@ public function provider()
                     'host'                 => env('CMQ_QUEUE_HOST', 'https://cmq-queue-region.api.qcloud.com'),
                     'name'                 => env('CMQ_QUEUE', 'default'),
                     'polling_wait_seconds' => env('CMQ_QUEUE_POLLING_WAIT_SECONDS', 0), //0-30seconds
-                    'retries'              => env('CMQ_QUEUE_RETRIES', 1),
+                    'retries'              => env('CMQ_QUEUE_RETRIES', 3),
                 ],
                 'topic' => [
                     'enable'  => env('CMQ_TOPIC_ENABLE', false),
                     'filter'  => env('CMQ_TOPIC_FILTER', 'routing'), //routing or msgtag
                     'host'    => env('CMQ_TOPIC_HOST', 'https://cmq-topic-region.api.qcloud.com'),
                     'name'    => env('CMQ_TOPIC'),
-                    'retries' => env('CMQ_TOPIC_RETRIES', 1),
+                    'retries' => env('CMQ_TOPIC_RETRIES', 3),
                 ],
             ],