freyo / laravel-queue-cmq

src/Queue/Driver/Message.php

Indentation +6 added lines, -6 removed lines

@@ -38,12 +38,12 @@
     public function __toString()
     {
         $info = ['msgBody'               => $this->msgBody,
-                      'msgId'            => $this->msgId,
-                      'enqueueTime'      => date('Y-m-d H:i:s', $this->enqueueTime),
-                      'nextVisibleTime'  => date('Y-m-d H:i:s', $this->nextVisibleTime),
-                      'firstDequeueTime' => date('Y-m-d H:i:s', $this->firstDequeueTime),
-                      'dequeueCount'     => $this->dequeueCount,
-                      'receiptHandle'    => $this->receiptHandle, ];
+                        'msgId'            => $this->msgId,
+                        'enqueueTime'      => date('Y-m-d H:i:s', $this->enqueueTime),
+                        'nextVisibleTime'  => date('Y-m-d H:i:s', $this->nextVisibleTime),
+                        'firstDequeueTime' => date('Y-m-d H:i:s', $this->firstDequeueTime),
+                        'dequeueCount'     => $this->dequeueCount,
+                        'receiptHandle'    => $this->receiptHandle, ];
 
         return json_encode($info);
     }

src/Queue/Driver/Account.php

Indentation +3 added lines, -3 removed lines

@@ -129,7 +129,7 @@ 
         }
 
         return ['totalCount'      => $ret_pkg['totalCount'],
-                     'queueList'  => $ret_pkg['queueList'], 'next_offset' => $next_offset, ];
+                        'queueList'  => $ret_pkg['queueList'], 'next_offset' => $next_offset, ];
     }
 
     /* 列出Account的主题
@@ -171,8 +171,8 @@ 
         }
 
         return ['totalCoult'       => $resp['totalCount'],
-                     'topicList'   => $resp['topicList'],
-                     'next_offset' => $next_offset, ];
+                        'topicList'   => $resp['topicList'],
+                        'next_offset' => $next_offset, ];
     }
 
     /* 获取Account的一个Topic对象

Spacing +2 added lines, -2 removed lines

@@ -122,7 +122,7 @@ 
         if ($offset == '') {
             $next_offset = count($ret_pkg['queueList']);
         } else {
-            $next_offset = (int) $offset + count($ret_pkg['queueList']);
+            $next_offset = (int)$offset + count($ret_pkg['queueList']);
         }
         if ($next_offset >= $ret_pkg['totalCount']) {
             $next_offset = '';
@@ -164,7 +164,7 @@ 
         if ($offset == '') {
             $next_offset = count($resp['topicList']);
         } else {
-            $next_offset = (int) $offset + count($resp['topicList']);
+            $next_offset = (int)$offset + count($resp['topicList']);
         }
         if ($next_offset >= $resp['totalCount']) {
             $next_offset = '';

src/Queue/Driver/CMQClient.php

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
         } elseif (strpos($host, 'https://') === 0) {
             $_host = substr($host, 8, strlen($host) - 8);
         } else {
-            throw new CMQClientParameterException('Only support http(s) prototol. Invalid endpoint:'.$host);
+            throw new CMQClientParameterException('Only support http(s) prototol. Invalid endpoint:' . $host);
         }
         if ($_host[strlen($_host) - 1] == '/') {
             $this->host = substr($_host, 0, strlen($_host) - 1);
@@ -46,7 +46,7 @@ 
         } elseif ($sign_method == 'sha256') {
             $this->sign_method = 'HmacSHA256';
         } else {
-            throw new CMQClientParameterException('Only support sign method HmasSHA256 or HmacSHA1 . Invalid sign method:'.$sign_method);
+            throw new CMQClientParameterException('Only support sign method HmasSHA256 or HmacSHA1 . Invalid sign method:' . $sign_method);
         }
     }
 
@@ -80,7 +80,7 @@ 
         $iTimeout = 0;
 
         if (array_key_exists('UserpollingWaitSeconds', $params)) {
-            $iTimeout = (int) $params['UserpollingWaitSeconds'];
+            $iTimeout = (int)$params['UserpollingWaitSeconds'];
         }
         // send request
         $resp_inter = $this->http->send_request($req_inter, $iTimeout);

src/Queue/Driver/ResponseInternal.php

Indentation +2 added lines, -2 removed lines

@@ -21,8 +21,8 @@
     public function __toString()
     {
         $info = ['status'      => $this->status,
-                      'header' => json_encode($this->header),
-                      'data'   => $this->data, ];
+                        'header' => json_encode($this->header),
+                        'data'   => $this->data, ];
 
         return json_encode($info);
     }

src/Queue/Driver/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -215,7 +215,7 @@ 
         ];
         $n = 1;
         foreach ($messages as $message) {
-            $key = 'msgBody.'.$n;
+            $key = 'msgBody.' . $n;
             if ($this->encoding) {
                 $params[$key] = base64_encode($message->msgBody);
             } else {
@@ -325,7 +325,7 @@ 
         $params = ['queueName' => $this->queue_name];
         $n = 1;
         foreach ($receipt_handle_list as $receipt_handle) {
-            $key = 'receiptHandle.'.$n;
+            $key = 'receiptHandle.' . $n;
             $params[$key] = $receipt_handle;
             $n += 1;
         }

src/LaravelQueueCMQServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -21,7 +21,7 @@ 
         }
         
         $this->mergeConfigFrom(
-            __DIR__.'/../config/cmq.php', 'queue.connections.cmq'
+            __DIR__ . '/../config/cmq.php', 'queue.connections.cmq'
         );
     }
 
@@ -35,7 +35,7 @@ 
         /** @var QueueManager $queue */
         $queue = $this->app['queue'];
 
-        $queue->addConnector('cmq', function () {
+        $queue->addConnector('cmq', function() {
             return new CMQConnector();
         });
     }

src/Queue/Driver/Subscription.php

Spacing +4 added lines, -4 removed lines

@@ -44,7 +44,7 @@ 
         if (is_array($subscription_meta->bindingKey) && !empty($subscription_meta->bindingKey)) {
             $n = 1;
             foreach ($subscription_meta->bindingKey as $tag) {
-                $key = 'bindingKey.'.$n;
+                $key = 'bindingKey.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -53,7 +53,7 @@ 
         if (is_array($subscription_meta->FilterTag) && !empty($subscription_meta->FilterTag)) {
             $n = 1;
             foreach ($subscription_meta->FilterTag as $tag) {
-                $key = 'filterTag.'.$n;
+                $key = 'filterTag.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -165,7 +165,7 @@ 
         if (is_array($subscription_meta->bindingKey) && !empty($subscription_meta->bindingKey)) {
             $n = 1;
             foreach ($subscription_meta->bindingKey as $tag) {
-                $key = 'bindingKey.'.$n;
+                $key = 'bindingKey.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -174,7 +174,7 @@ 
         if (is_array($subscription_meta->FilterTag) && !empty($subscription_meta->FilterTag)) {
             $n = 1;
             foreach ($subscription_meta->FilterTag as $tag) {
-                $key = 'filterTag.'.$n;
+                $key = 'filterTag.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }

src/Queue/Driver/CMQHttp.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
     {
         $this->connection_timeout = $connection_timeout;
         $this->keep_alive = $keep_alive;
-        $this->host = $host.'/v2/index.php';
+        $this->host = $host . '/v2/index.php';
         $this->curl = null;
     }
 
@@ -55,7 +55,7 @@ 
             curl_setopt($this->curl, CURLOPT_POST, 1);
             curl_setopt($this->curl, CURLOPT_POSTFIELDS, $req_inter->data);
         } else {
-            $url .= $req_inter->uri.'?'.$req_inter->data;
+            $url .= $req_inter->uri . '?' . $req_inter->data;
         }
 
         if (isset($req_inter->header)) {

src/Queue/CMQQueue.php

Spacing +7 added lines, -7 removed lines

@@ -75,7 +75,7 @@ 
      */
     public function isPlain()
     {
-        return (bool) Arr::get($this->plainOptions, 'enable');
+        return (bool)Arr::get($this->plainOptions, 'enable');
     }
 
     /**
@@ -97,7 +97,7 @@ 
     {
         $attributes = $this->getQueue($queue)->get_attributes();
 
-        return (int) $attributes->activeMsgNum;
+        return (int)$attributes->activeMsgNum;
     }
 
     /**
@@ -147,22 +147,22 @@ 
             switch ($this->topicOptions['filter']) {
                 case self::CMQ_TOPIC_TAG_FILTER_NAME:
                     return retry(Arr::get($this->topicOptions, 'retries', 3),
-                        function () use ($driver, $message, $queue) {
+                        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', 3),
-                        function () use ($driver, $message, $queue) {
+                        function() use ($driver, $message, $queue) {
                             $driver->publish_message($message->msgBody, [], $queue);
                         });
                 default:
                     throw new \InvalidArgumentException(
-                        'Invalid CMQ topic filter: '.$this->topicOptions['filter']
+                        'Invalid CMQ topic filter: ' . $this->topicOptions['filter']
                     );
             }
         }
 
-        return retry(Arr::get($this->queueOptions, 'retries', 3), 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));
         });
     }
@@ -209,7 +209,7 @@ 
             $queue = $this->getQueue($queue);
             $message = $queue->receive_message($this->queueOptions['polling_wait_seconds']);
         } catch (CMQServerException $e) {
-            if (self::CMQ_QUEUE_NO_MESSAGE_CODE === (int) $e->getCode()) { // ignore no message
+            if (self::CMQ_QUEUE_NO_MESSAGE_CODE === (int)$e->getCode()) { // ignore no message
                 return;
             }