Skip to content

Commit f7a3f9d

Browse files
authored
Merge pull request #593 from villfa/patch-1
Document the exceptions thrown by publishBasic()
2 parents 3d58891 + 813086a commit f7a3f9d

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/Queue/RabbitMQQueue.php

+6
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
use PhpAmqpLib\Channel\AMQPChannel;
1616
use PhpAmqpLib\Connection\AbstractConnection;
1717
use PhpAmqpLib\Exception\AMQPChannelClosedException;
18+
use PhpAmqpLib\Exception\AMQPConnectionBlockedException;
1819
use PhpAmqpLib\Exception\AMQPConnectionClosedException;
1920
use PhpAmqpLib\Exception\AMQPProtocolChannelException;
2021
use PhpAmqpLib\Exception\AMQPRuntimeException;
@@ -739,6 +740,11 @@ protected function getConfig(): QueueConfig
739740
return $this->config;
740741
}
741742

743+
/**
744+
* @throws AMQPChannelClosedException
745+
* @throws AMQPConnectionClosedException
746+
* @throws AMQPConnectionBlockedException
747+
*/
742748
protected function publishBasic($msg, $exchange = '', $destination = '', $mandatory = false, $immediate = false, $ticket = null): void
743749
{
744750
$this->getChannel()->basic_publish($msg, $exchange, $destination, $mandatory, $immediate, $ticket);

0 commit comments

Comments
 (0)