diff --git a/src/Codeception/Module/AMQP.php b/src/Codeception/Module/AMQP.php index 9c23c3e..03ac83b 100644 --- a/src/Codeception/Module/AMQP.php +++ b/src/Codeception/Module/AMQP.php @@ -109,7 +109,7 @@ public function _before(TestInterface $test): void * $I->pushToExchange('exchange.emails', new AMQPMessage('Thanks!'), 'severity'); * ``` */ - public function pushToExchange(string $exchange, string|AMQPMessage $message, string $routing_key = null): void + public function pushToExchange(string $exchange, string|AMQPMessage $message, ?string $routing_key = null): void { $message = $message instanceof AMQPMessage ? $message @@ -159,8 +159,8 @@ public function declareExchange( bool $auto_delete = true, bool $internal = false, bool $nowait = false, - array $arguments = null, - int $ticket = null + ?array $arguments = null, + ?int $ticket = null ) { return $this->getChannel()->exchange_declare( $exchange, @@ -196,8 +196,8 @@ public function declareQueue( bool $exclusive = false, bool $auto_delete = true, bool $nowait = false, - array $arguments = null, - int $ticket = null + ?array $arguments = null, + ?int $ticket = null ): ?array { return $this->getChannel()->queue_declare( $queue, @@ -232,8 +232,8 @@ public function bindQueueToExchange( string $exchange, string $routing_key = '', bool $nowait = false, - array $arguments = null, - int $ticket = null + ?array $arguments = null, + ?int $ticket = null ) { return $this->getChannel()->queue_bind( $queue,