@@ -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 | ] |
@@ -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, |