[Messenger] Display a nice error when connection fail
This commit is contained in:
parent
0762d2d9ac
commit
eac014febd
@ -199,10 +199,14 @@ class Connection
|
|||||||
$connection = $this->amqpFactory->createConnection($this->connectionCredentials);
|
$connection = $this->amqpFactory->createConnection($this->connectionCredentials);
|
||||||
$connectMethod = 'true' === ($this->connectionCredentials['persistent'] ?? 'false') ? 'pconnect' : 'connect';
|
$connectMethod = 'true' === ($this->connectionCredentials['persistent'] ?? 'false') ? 'pconnect' : 'connect';
|
||||||
|
|
||||||
if (false === $connection->{$connectMethod}()) {
|
try {
|
||||||
throw new \AMQPException('Could not connect to the AMQP server. Please verify the provided DSN.');
|
$connection->{$connectMethod}();
|
||||||
}
|
} catch (\AMQPConnectionException $e) {
|
||||||
|
$credentials = $this->connectionCredentials;
|
||||||
|
$credentials['password'] = '********';
|
||||||
|
|
||||||
|
throw new \AMQPException(sprintf('Could not connect to the AMQP server. Please verify the provided DSN. (%s)', json_encode($credentials)), 0, $e);
|
||||||
|
}
|
||||||
$this->amqpChannel = $this->amqpFactory->createChannel($connection);
|
$this->amqpChannel = $this->amqpFactory->createChannel($connection);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user