From 0b10f26c3cf4c6ecf13ef24dd6fd87fefa80006b Mon Sep 17 00:00:00 2001 From: Denux Date: Fri, 5 Dec 2025 13:47:59 +0100 Subject: [PATCH] Added support for AMQPTable --- src/Codeception/Module/AMQP.php | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/Codeception/Module/AMQP.php b/src/Codeception/Module/AMQP.php index ff70cd9..2015ecc 100644 --- a/src/Codeception/Module/AMQP.php +++ b/src/Codeception/Module/AMQP.php @@ -13,6 +13,7 @@ use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Exception\AMQPProtocolChannelException; use PhpAmqpLib\Message\AMQPMessage; +use PhpAmqpLib\Wire\AMQPTable; /** * This module interacts with message broker software that implements @@ -166,7 +167,7 @@ public function declareExchange( bool $auto_delete = true, bool $internal = false, bool $nowait = false, - ?array $arguments = null, + array|AMQPTable|null $arguments = null, ?int $ticket = null ) { return $this->getChannel()->exchange_declare( @@ -203,7 +204,7 @@ public function declareQueue( bool $exclusive = false, bool $auto_delete = true, bool $nowait = false, - ?array $arguments = null, + array|AMQPTable|null $arguments = null, ?int $ticket = null ): ?array { return $this->getChannel()->queue_declare( @@ -239,7 +240,7 @@ public function bindQueueToExchange( string $exchange, string $routing_key = '', bool $nowait = false, - ?array $arguments = null, + array|AMQPTable|null $arguments = null, ?int $ticket = null ) { return $this->getChannel()->queue_bind(