Merge branch 'master' into master

CHANGELOG-12x.md

@@ -2,7 +2,11 @@
 
 All notable changes to this project will be documented in this file.
 
-## [Unreleased](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v12.0.0...master)
+## [Unreleased](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v12.0.1...master)
+
+## [12.0.1 (2022-04-06)](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v12.0.0...v12.0.1)
+
+- Allow laravel to end workers with lost connection [#457](https://github.com/vyuldashev/laravel-queue-rabbitmq/pull/457)
 
 ## [12.0.0 (2022-02-23)](https://github.com/vyuldashev/laravel-queue-rabbitmq/compare/v11.4.0...v12.0.0)
 

src/Console/ExchangeDeclareCommand.php

@@ -18,7 +18,8 @@ class ExchangeDeclareCommand extends Command
     protected $description = 'Declare exchange';
 
     /**
-     * @param RabbitMQConnector $connector
+     * @param  RabbitMQConnector  $connector
+     *
      * @throws Exception
      */
     public function handle(RabbitMQConnector $connector): void

src/Console/ExchangeDeleteCommand.php

@@ -16,7 +16,8 @@ class ExchangeDeleteCommand extends Command
     protected $description = 'Delete exchange';
 
     /**
-     * @param RabbitMQConnector $connector
+     * @param  RabbitMQConnector  $connector
+     *
      * @throws Exception
      */
     public function handle(RabbitMQConnector $connector): void

src/Console/QueueBindCommand.php

@@ -17,7 +17,8 @@ class QueueBindCommand extends Command
     protected $description = 'Bind queue to exchange';
 
     /**
-     * @param RabbitMQConnector $connector
+     * @param  RabbitMQConnector  $connector
+     *
      * @throws Exception
      */
     public function handle(RabbitMQConnector $connector): void

src/Console/QueueDeclareCommand.php

@@ -19,7 +19,8 @@ class QueueDeclareCommand extends Command
     protected $description = 'Declare queue';
 
     /**
-     * @param RabbitMQConnector $connector
+     * @param  RabbitMQConnector  $connector
+     *
      * @throws Exception
      */
     public function handle(RabbitMQConnector $connector): void

src/Console/QueueDeleteCommand.php

@@ -17,7 +17,8 @@ class QueueDeleteCommand extends Command
     protected $description = 'Delete queue';
 
     /**
-     * @param RabbitMQConnector $connector
+     * @param  RabbitMQConnector  $connector
+     *
      * @throws Exception
      */
     public function handle(RabbitMQConnector $connector): void

src/Console/QueuePurgeCommand.php

@@ -19,7 +19,8 @@ class QueuePurgeCommand extends Command
     protected $description = 'Purge all messages in queue';
 
     /**
-     * @param RabbitMQConnector $connector
+     * @param  RabbitMQConnector  $connector
+     *
      * @throws Exception
      */
     public function handle(RabbitMQConnector $connector): void

src/Consumer.php

@@ -63,10 +63,11 @@ public function setPrefetchCount(int $value): void
     /**
      * Listen to the given queue in a loop.
      *
-     * @param string $connectionName
-     * @param string $queue
-     * @param WorkerOptions $options
+     * @param  string  $connectionName
+     * @param  string  $queue
+     * @param  WorkerOptions  $options
      * @return int
+     *
      * @throws Throwable
      */
     public function daemon($connectionName, $queue, WorkerOptions $options)
@@ -147,7 +148,7 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
                 $this->exceptions->report($exception);
 
                 $this->kill(1);
-            } catch (Exception | Throwable $exception) {
+            } catch (Exception|Throwable $exception) {
                 $this->exceptions->report($exception);
 
                 $this->stopWorkerIfLostConnection($exception);
@@ -180,9 +181,9 @@ function (AMQPMessage $message) use ($connection, $options, $connectionName, $qu
     /**
      * Determine if the daemon should process on this iteration.
      *
-     * @param WorkerOptions $options
-     * @param string $connectionName
-     * @param string $queue
+     * @param  WorkerOptions  $options
+     * @param  string  $connectionName
+     * @param  string  $queue
      * @return bool
      */
     protected function daemonShouldRun(WorkerOptions $options, $connectionName, $queue): bool

src/Horizon/Listeners/RabbitMQFailedEvent.php

@@ -19,7 +19,7 @@ class RabbitMQFailedEvent
     /**
      * Create a new listener instance.
      *
-     * @param Dispatcher $events
+     * @param  Dispatcher  $events
      * @return void
      */
     public function __construct(Dispatcher $events)
@@ -30,7 +30,7 @@ public function __construct(Dispatcher $events)
     /**
      * Handle the event.
      *
-     * @param LaravelJobFailed $event
+     * @param  LaravelJobFailed  $event
      * @return void
      */
     public function handle(LaravelJobFailed $event): void

src/Horizon/RabbitMQQueue.php

@@ -25,8 +25,9 @@ class RabbitMQQueue extends BaseRabbitMQQueue
     /**
      * Get the number of queue jobs that are ready to process.
      *
-     * @param string|null $queue
+     * @param  string|null  $queue
      * @return int
+     *
      * @throws AMQPProtocolChannelException
      */
     public function readyNow($queue = null): int
@@ -93,9 +94,10 @@ public function release($delay, $job, $data, $queue, $attempts = 0)
     /**
      * Fire the job deleted event.
      *
-     * @param  string $queue
-     * @param  RabbitMQJob $job
+     * @param  string  $queue
+     * @param  RabbitMQJob  $job
      * @return void
+     *
      * @throws BindingResolutionException
      */
     public function deleteReserved($queue, $job): void
@@ -106,9 +108,10 @@ public function deleteReserved($queue, $job): void
     /**
      * Fire the given event if a dispatcher is bound.
      *
-     * @param  string $queue
-     * @param  mixed $event
+     * @param  string  $queue
+     * @param  mixed  $event
      * @return void
+     *
      * @throws BindingResolutionException
      */
     protected function event($queue, $event): void

src/Queue/Connectors/RabbitMQConnector.php

@@ -31,9 +31,9 @@ public function __construct(Dispatcher $dispatcher)
     /**
      * Establish a queue connection.
      *
-     * @param array $config
-     *
+     * @param  array  $config
      * @return RabbitMQQueue
+     *
      * @throws Exception
      */
     public function connect(array $config): Queue
@@ -64,8 +64,9 @@ public function connect(array $config): Queue
     }
 
     /**
-     * @param array $config
+     * @param  array  $config
      * @return AbstractConnection
+     *
      * @throws Exception
      */
     protected function createConnection(array $config): AbstractConnection
@@ -112,7 +113,7 @@ protected function createQueue(
     /**
      * Recursively filter only null values.
      *
-     * @param array $array
+     * @param  array  $array
      * @return array
      */
     private function filter(array $array): array

src/Queue/Jobs/RabbitMQJob.php

@@ -118,7 +118,8 @@ public function delete(): void
     /**
      * Release the job back into the queue.
      *
-     * @param int $delay
+     * @param  int  $delay
+     *
      * @throws AMQPProtocolChannelException
      */
     public function release($delay = 0): void