diff --git a/src/Driver/PhpAmqpLib/Queue.php b/src/Driver/PhpAmqpLib/Queue.php index b5cf614..c8eb557 100644 --- a/src/Driver/PhpAmqpLib/Queue.php +++ b/src/Driver/PhpAmqpLib/Queue.php @@ -190,7 +190,7 @@ public function consume( while ($this->channel->getResource()->is_consuming()) { $this->channel->getResource()->wait(null, false, $readTimeout); } - } catch (\Throwable $e) { + } catch (\Exception $e) { throw Exception\QueueException::fromPhpAmqpLib($e); } }