milkmeowo / laravel-queue-aliyun-mns

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