freyo / laravel-queue-cmq

src/Queue/Driver/CMQServerNetworkException.php

Indentation +2 added lines, -2 removed lines

@@ -23,8 +23,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 'CMQServerNetworkException  '.json_encode($info);
     }

Spacing +1 added lines, -1 removed lines

@@ -26,6 +26,6 @@
                       'header' => json_encode($this->header),
                       'data'   => $this->data, ];
 
-        return 'CMQServerNetworkException  '.json_encode($info);
+        return 'CMQServerNetworkException  ' . json_encode($info);
     }
 }

src/Queue/Driver/Subscription.php

Spacing +4 added lines, -4 removed lines

@@ -44,7 +44,7 @@ 
         if (!$subscription_meta->bindindKey != null && is_array($subscription_meta->bindindKey) && !empty($subscription_meta->bindindKey)) {
             $n = 1;
             foreach ($subscription_meta->bindindKey as $tag) {
-                $key = 'bindindKey.'.$n;
+                $key = 'bindindKey.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -53,7 +53,7 @@ 
         if (!$subscription_meta->FilterTag != null && 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 (!$subscription_meta->bindindKey != null && is_array($subscription_meta->bindindKey) && !empty($subscription_meta->bindindKey)) {
             $n = 1;
             foreach ($subscription_meta->bindindKey as $tag) {
-                $key = 'bindindKey.'.$n;
+                $key = 'bindindKey.' . $n;
                 $params[$key] = $tag;
                 $n += 1;
             }
@@ -174,7 +174,7 @@ 
         if (!$subscription_meta->FilterTag != null && 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/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/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/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

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