milkmeowo / laravel-queue-aliyun-mns

lib/AliyunMNS/Responses/GetAccountAttributesResponse.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
         } catch (\Exception $e) {
             if ($exception != NULL) {
                 throw $exception;
-            } elseif($e instanceof MnsException) {
+            } elseif ($e instanceof MnsException) {
                 throw $e;
             } else {
                 throw new MnsException($statusCode, $e->getMessage());

lib/AliyunMNS/Responses/PublishMessageResponse.php

Spacing +1 added lines, -1 removed lines

@@ -60,7 +60,7 @@
         } catch (\Exception $e) {
             if ($exception != NULL) {
                 throw $exception;
-            } elseif($e instanceof MnsException) {
+            } elseif ($e instanceof MnsException) {
                 throw $e;
             } else {
                 throw new MnsException($statusCode, $e->getMessage());

lib/AliyunMNS/Responses/CreateTopicResponse.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         } catch (\Exception $e) {
             if ($exception != NULL) {
                 throw $exception;
-            } elseif($e instanceof MnsException) {
+            } elseif ($e instanceof MnsException) {
                 throw $e;
             } else {
                 throw new MnsException($statusCode, $e->getMessage());

lib/AliyunMNS/Responses/ListQueueResponse.php

Spacing +1 added lines, -1 removed lines

@@ -95,7 +95,7 @@
         } catch (\Exception $e) {
             if ($exception != NULL) {
                 throw $exception;
-            } elseif($e instanceof MnsException) {
+            } elseif ($e instanceof MnsException) {
                 throw $e;
             } else {
                 throw new MnsException($statusCode, $e->getMessage());

lib/AliyunMNS/Responses/DeleteTopicResponse.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
         } catch (\Exception $e) {
             if ($exception != NULL) {
                 throw $exception;
-            } elseif($e instanceof MnsException) {
+            } elseif ($e instanceof MnsException) {
                 throw $e;
             } else {
                 throw new MnsException($statusCode, $e->getMessage());

lib/AliyunMNS/Responses/BatchSendMessageResponse.php

Spacing +2 added lines, -2 removed lines

@@ -73,7 +73,7 @@ 
         } catch (\Exception $e) {
             if ($exception != NULL) {
                 throw $exception;
-            } elseif($e instanceof MnsException) {
+            } elseif ($e instanceof MnsException) {
                 throw $e;
             } else {
                 throw new MnsException($statusCode, $e->getMessage());
@@ -89,7 +89,7 @@ 
         while ($xmlReader->read())
         {
             if ($xmlReader->nodeType == \XMLReader::ELEMENT && $xmlReader->name == 'Message') {
-                $ex->addSendMessageResponseItem( SendMessageResponseItem::fromXML($xmlReader));
+                $ex->addSendMessageResponseItem(SendMessageResponseItem::fromXML($xmlReader));
             }
         }
         throw $ex;

src/LaravelMnsServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
      */
     protected function registerConnector($manager)
     {
-        $manager->addConnector('mns', function () {
+        $manager->addConnector('mns', function() {
             return new MnsConnector();
         });
     }

src/Console/MnsListQueueCommand.php

Spacing +2 added lines, -2 removed lines

@@ -70,11 +70,11 @@
             }
             $marker = $res->getNextMarker();
             if ($marker) {
-                $this->question('---下一页:['.base64_decode($marker).']---');
+                $this->question('---下一页:[' . base64_decode($marker) . ']---');
                 $this->listQueue($client, $prefix, $marker);
             }
         } catch (MnsException $e) {
-            $this->error('查询队列失败:'.$e);
+            $this->error('查询队列失败:' . $e);
         }
     }
 }

src/Console/MnsShowQueueCommand.php

Spacing +8 added lines, -8 removed lines

@@ -49,7 +49,7 @@ 
         }
         $client = new Client($config['endpoint'], $config['key'], $config['secret']);
         $queue = $client->getQueueRef($queueName);
-        $this->alert('队列:'.$queueName);
+        $this->alert('队列:' . $queueName);
         $this->info('拉取信息中...');
 
         try {
@@ -60,13 +60,13 @@ 
                  */
                 foreach ($messages as $message) {
                     $this->info('------------');
-                    $this->info('消息编号'.$message->getMessageId());
-                    $this->info('消息正文的 MD5 值'.$message->getMessageBodyMD5());
-                    $this->info('消息正文'.$message->getMessageBody());
-                    $this->info('消息发送到队列的时间'.$message->getEnqueueTime());
-                    $this->info('第一次被消费的时间'.$message->getFirstDequeueTime());
-                    $this->info('总共被消费的次数'.$message->getDequeueCount());
-                    $this->info('消息的优先级权值'.$message->getPriority());
+                    $this->info('消息编号' . $message->getMessageId());
+                    $this->info('消息正文的 MD5 值' . $message->getMessageBodyMD5());
+                    $this->info('消息正文' . $message->getMessageBody());
+                    $this->info('消息发送到队列的时间' . $message->getEnqueueTime());
+                    $this->info('第一次被消费的时间' . $message->getFirstDequeueTime());
+                    $this->info('总共被消费的次数' . $message->getDequeueCount());
+                    $this->info('消息的优先级权值' . $message->getPriority());
                     $this->info('------------');
                 }
             }