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(