freyo / laravel-queue-cmq

src/Queue/Driver/CMQClientParameterException.php

Spacing +1 added lines, -1 removed lines

@@ -15,6 +15,6 @@
 
     public function __toString()
     {
-        return 'CMQClientParameterException  '.$this->get_info();
+        return 'CMQClientParameterException  ' . $this->get_info();
     }
 }

src/Queue/Driver/QueueMeta.php

Indentation +13 added lines, -13 removed lines

@@ -59,19 +59,19 @@
     public function __toString()
     {
         $info = ['visibilityTimeout'        => $this->visibilityTimeout,
-                      'maxMsgHeapNum'       => $this->maxMsgHeapNum,
-                      'maxMsgSize'          => $this->maxMsgSize,
-                      'msgRetentionSeconds' => $this->msgRetentionSeconds,
-                      'pollingWaitSeconds'  => $this->pollingWaitSeconds,
-                      'activeMsgNum'        => $this->activeMsgNum,
-                      'inactiveMsgNum'      => $this->inactiveMsgNum,
-                      'createTime'          => date('Y-m-d H:i:s', $this->createTime),
-                      'lastModifyTime'      => date('Y-m-d H:i:s', $this->lastModifyTime),
-                      'QueueName'           => $this->queueName,
-                      'rewindSeconds'       => $this->rewindSeconds,
-                      'rewindmsgNum'        => $this->rewindmsgNum,
-                      'minMsgTime'          => $this->minMsgTime,
-                      'delayMsgNum'         => $this->delayMsgNum, ];
+                        'maxMsgHeapNum'       => $this->maxMsgHeapNum,
+                        'maxMsgSize'          => $this->maxMsgSize,
+                        'msgRetentionSeconds' => $this->msgRetentionSeconds,
+                        'pollingWaitSeconds'  => $this->pollingWaitSeconds,
+                        'activeMsgNum'        => $this->activeMsgNum,
+                        'inactiveMsgNum'      => $this->inactiveMsgNum,
+                        'createTime'          => date('Y-m-d H:i:s', $this->createTime),
+                        'lastModifyTime'      => date('Y-m-d H:i:s', $this->lastModifyTime),
+                        'QueueName'           => $this->queueName,
+                        'rewindSeconds'       => $this->rewindSeconds,
+                        'rewindmsgNum'        => $this->rewindmsgNum,
+                        'minMsgTime'          => $this->minMsgTime,
+                        'delayMsgNum'         => $this->delayMsgNum, ];
 
         return json_encode($info);
     }

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);
     }