yuanxing008 / laravel-aliyun-amqp

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
         ]

src/Entity/QueueEntity.php

Spacing +1 added lines, -1 removed lines

@@ -416,7 +416,7 @@
     private function registerShutdownHandler()
     {
         $consumer = $this;
-        register_shutdown_function(function () use ($consumer) {
+        register_shutdown_function(function() use ($consumer) {
             $consumer->stopConsuming();
         });
     }

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)) {

src/AMQPConnection.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,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,