From 8cb6c2d65b43efa4d1a6c6bb2109dbad6b3c1e68 Mon Sep 17 00:00:00 2001 From: Netkas Date: Thu, 9 Feb 2023 17:27:24 -0500 Subject: [PATCH] Disabled RabbitMQ --- src/TamerLib/Classes/Functions.php | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/TamerLib/Classes/Functions.php b/src/TamerLib/Classes/Functions.php index 34e7e58..0d4f759 100644 --- a/src/TamerLib/Classes/Functions.php +++ b/src/TamerLib/Classes/Functions.php @@ -1,5 +1,7 @@ new \TamerLib\Protocols\Gearman\Client($username, $password), - ProtocolType::RabbitMQ => new \TamerLib\Protocols\RabbitMq\Client($username, $password), + ProtocolType::RabbitMQ => throw new InvalidArgumentException('RabbitMQ is not fully implemented yet'), default => throw new InvalidArgumentException('Invalid protocol type'), }; } @@ -78,7 +80,7 @@ return match (strtolower($protocol)) { ProtocolType::Gearman => new \TamerLib\Protocols\Gearman\Worker($username, $password), - ProtocolType::RabbitMQ => new \TamerLib\Protocols\RabbitMq\Worker($username, $password), + ProtocolType::RabbitMQ => throw new InvalidArgumentException('RabbitMQ is not fully implemented yet'), default => throw new InvalidArgumentException('Invalid protocol type'), }; }