Exception thrown by ::pop is checked by Illuminate\Database\DetectsLostConnections::causedByLostConnection (vyuldashev#457)

It should throw exception with special message in order to end queue on error correctly.
Otherwise, it continues to work with broken connection.

Author: violarium

src/Queue/RabbitMQQueue.php

@@ -13,7 +13,10 @@
 use JsonException;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Connection\AbstractConnection;
+use PhpAmqpLib\Exception\AMQPChannelClosedException;
+use PhpAmqpLib\Exception\AMQPConnectionClosedException;
 use PhpAmqpLib\Exception\AMQPProtocolChannelException;
+use PhpAmqpLib\Exception\AMQPRuntimeException;
 use PhpAmqpLib\Exchange\AMQPExchangeType;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Wire\AMQPTable;
@@ -254,6 +257,16 @@ public function pop($queue = null)
             }
 
             throw $exception;
+        } catch (AMQPChannelClosedException|AMQPConnectionClosedException $exception) {
+            // Queue::pop used by worker to receive new job
+            // Thrown exception is checked by Illuminate\Database\DetectsLostConnections::causedByLostConnection
+            // Is has to contain one of the several phrases in exception message in order to restart worker
+            // Otherwise worker continues to work with broken connection
+            throw new AMQPRuntimeException(
+                'Lost connection: '.$exception->getMessage(),
+                $exception->getCode(),
+                $exception
+            );
         }
 
         return null;