@@ -416,7 +416,7 @@ |
||
| 416 | 416 | private function registerShutdownHandler() |
| 417 | 417 | { |
| 418 | 418 | $consumer = $this; |
| 419 | - register_shutdown_function(function () use ($consumer) { |
|
| 419 | + register_shutdown_function(function() use ($consumer) { |
|
| 420 | 420 | $consumer->stopConsuming(); |
| 421 | 421 | }); |
| 422 | 422 | } |
@@ -80,7 +80,7 @@ discard block |
||
| 80 | 80 | |
| 81 | 81 | $this->app->singleton( |
| 82 | 82 | Container::class, |
| 83 | - function () use ($config) { |
|
| 83 | + function() use ($config) { |
|
| 84 | 84 | $container = new ContainerBuilder(); |
| 85 | 85 | return $container->createContainer($config); |
| 86 | 86 | } |
@@ -93,7 +93,7 @@ discard block |
||
| 93 | 93 | private function registerPublishers() |
| 94 | 94 | { |
| 95 | 95 | // Get "tagged" like Publisher |
| 96 | - $this->app->singleton(PublisherInterface::class, function (Application $application, $arguments) { |
|
| 96 | + $this->app->singleton(PublisherInterface::class, function(Application $application, $arguments) { |
|
| 97 | 97 | /** @var Container $container */ |
| 98 | 98 | $container = $application->make(Container::class); |
| 99 | 99 | if (empty($arguments)) { |
@@ -110,7 +110,7 @@ discard block |
||
| 110 | 110 | private function registerConsumers() |
| 111 | 111 | { |
| 112 | 112 | // Get "tagged" like Consumers |
| 113 | - $this->app->singleton(ConsumerInterface::class, function (Application $application, $arguments) { |
|
| 113 | + $this->app->singleton(ConsumerInterface::class, function(Application $application, $arguments) { |
|
| 114 | 114 | /** @var Container $container */ |
| 115 | 115 | $container = $application->make(Container::class); |
| 116 | 116 | if (empty($arguments)) { |
@@ -32,7 +32,7 @@ |
||
| 32 | 32 | 'lazy' => true, |
| 33 | 33 | |
| 34 | 34 | # More info about timeouts can be found on https://www.rabbitmq.com/networking.html |
| 35 | - 'read_write_timeout' => 3, // default timeout for writing/reading (in seconds) |
|
| 35 | + 'read_write_timeout' => 3, // default timeout for writing/reading (in seconds) |
|
| 36 | 36 | 'connect_timeout' => 3, |
| 37 | 37 | 'heartbeat' => 0, |
| 38 | 38 | 'keep_alive' => false, |
@@ -14,7 +14,7 @@ |
||
| 14 | 14 | 'lazy' => true, |
| 15 | 15 | |
| 16 | 16 | # More info about timeouts can be found on https://www.rabbitmq.com/networking.html |
| 17 | - 'read_write_timeout' => 8, // default timeout for writing/reading (in seconds) |
|
| 17 | + 'read_write_timeout' => 8, // default timeout for writing/reading (in seconds) |
|
| 18 | 18 | 'connect_timeout' => 10, |
| 19 | 19 | 'heartbeat' => 4, |
| 20 | 20 | 'access_key'=>'', |