milkmeowo / laravel-queue-aliyun-mns

lib/AliyunMNS/Responses/SubscribeResponse.php

Braces +5 added lines, -10 removed lines

@@ -16,8 +16,7 @@ 
         if ($statusCode == 201 || $statusCode == 204)
         {
             $this->succeed = TRUE;
-        }
-        else
+        } else
         {
             $this->parseErrorResponse($statusCode, $content);
         }
@@ -40,23 +39,19 @@ 
                 throw new SubscriptionAlreadyExistException($statusCode, $result['Message'], $exception, $result['Code'], $result['RequestId'], $result['HostId']);
             }
             throw new MnsException($statusCode, $result['Message'], $exception, $result['Code'], $result['RequestId'], $result['HostId']);
-        }
-        catch (\Exception $e)
+        } catch (\Exception $e)
         {
             if ($exception != NULL)
             {
                 throw $exception;
-            }
-            elseif ($e instanceof MnsException)
+            } elseif ($e instanceof MnsException)
             {
                 throw $e;
-            }
-            else
+            } else
             {
                 throw new MnsException($statusCode, $e->getMessage());
             }
-        }
-        catch (\Throwable $t)
+        } catch (\Throwable $t)
         {
             throw new MnsException($statusCode, $t->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('------------');
                 }
             }

src/Console/MnsDeleteQueueCommand.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
             $this->info('队列删除成功');
             $this->alert($queue);
         } catch (MnsException $e) {
-            $this->error('队列删除失败:'.$e);
+            $this->error('队列删除失败:' . $e);
         }
     }
 }

src/Console/MnsFlushCommand.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         if (!$queue) {
             $queue = $config['queue'];
         }
-        $this->alert('队列：'.$queue);
+        $this->alert('队列：' . $queue);
         $client = new Client($config['endpoint'], $config['key'], $config['secret']);
         $queue = $client->getQueueRef($queue);
         $hasMessage = true;

src/Console/MnsCreateQueueCommand.php

Spacing +1 added lines, -1 removed lines

@@ -55,7 +55,7 @@
             $this->info('队列创建成功');
             $this->alert($queue);
         } catch (MnsException $e) {
-            $this->error('队列创建失败:'.$e);
+            $this->error('队列创建失败:' . $e);
         }
     }
 }

lib/AliyunMNS/Responses/BatchReceiveMessageResponse.php

Spacing +1 added lines, -1 removed lines

@@ -50,7 +50,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());