yuanxing008 / laravel-aliyun-amqp

src/Providers/ServiceProvider.php

Spacing +3 added lines, -3 removed lines

@@ -80,7 +80,7 @@ 
 
         $this->app->singleton(
             Container::class,
-            function () use ($config) {
+            function() use ($config) {
                 $container = new ContainerBuilder();
                 return $container->createContainer($config);
             }
@@ -93,7 +93,7 @@ 
     private function registerPublishers()
     {
         // Get "tagged" like Publisher
-        $this->app->singleton(PublisherInterface::class, function (Application $application, $arguments) {
+        $this->app->singleton(PublisherInterface::class, function(Application $application, $arguments) {
             /** @var Container $container */
             $container = $application->make(Container::class);
             if (empty($arguments)) {
@@ -110,7 +110,7 @@ 
     private function registerConsumers()
     {
         // Get "tagged" like Consumers
-        $this->app->singleton(ConsumerInterface::class, function (Application $application, $arguments) {
+        $this->app->singleton(ConsumerInterface::class, function(Application $application, $arguments) {
             /** @var Container $container */
             $container = $application->make(Container::class);
             if (empty($arguments)) {

config/laravel_rabbitmq_example.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
             'lazy'               => true,
 
             # More info about timeouts can be found on https://www.rabbitmq.com/networking.html
-            'read_write_timeout' => 8,   // default timeout for writing/reading (in seconds)
+            'read_write_timeout' => 8, // default timeout for writing/reading (in seconds)
             'connect_timeout'    => 10,
             'heartbeat'          => 4,
             'access_key'=>'',

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

src/AMQPConnection.php

Spacing +2 added lines, -2 removed lines

@@ -38,7 +38,7 @@ 
         'lazy' => true,
 
         # More info about timeouts can be found on https://www.rabbitmq.com/networking.html
-        'read_write_timeout' => 3,   // default timeout for writing/reading (in seconds)
+        'read_write_timeout' => 3, // default timeout for writing/reading (in seconds)
         'connect_timeout' => 3,
         'heartbeat' => 0,
         'keep_alive' => false,
@@ -218,7 +218,7 @@ 
             $this->getConnection()->reconnect();
         } catch (AMQPChannelClosedException $e) {
             $this->logger->info('channel was closed');
-        } catch (AMQPConnectionClosedException $e){
+        } catch (AMQPConnectionClosedException $e) {
             $this->getConnection()->reconnect();
             $this->logger->info('connection was closed');
         }