yuanxing008 / laravel-aliyun-amqp

src/Entity/QueueEntity.php

Spacing +2 added lines, -2 removed lines

@@ -298,7 +298,7 @@ 
             try {
                 $this->getChannel()->wait();
             } catch (AMQPTimeoutException $e) {
-                $this->logger->debug('startConsuming Exception--->'.$e->getMessage());
+                $this->logger->debug('startConsuming Exception--->' . $e->getMessage());
                 usleep(1000);
                 $this->getConnection()->reconnect();
                 $this->setupChannelConsumer();
@@ -417,7 +417,7 @@ 
     private function registerShutdownHandler()
     {
         $consumer = $this;
-        register_shutdown_function(function () use ($consumer) {
+        register_shutdown_function(function() use ($consumer) {
             $consumer->stopConsuming();
         });
     }