Ensure an exception is thrown when the AMQP connect() does not work
This commit is contained in:
parent
6ff11858b1
commit
46b9476b52
@ -335,6 +335,27 @@ class ConnectionTest extends TestCase
|
|||||||
$delayExchange->expects($this->once())->method('publish')->with('{}', 'delay_120000', AMQP_NOPARAM, ['headers' => []]);
|
$delayExchange->expects($this->once())->method('publish')->with('{}', 'delay_120000', AMQP_NOPARAM, ['headers' => []]);
|
||||||
$connection->publish('{}', [], 120000);
|
$connection->publish('{}', [], 120000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @expectedException \AMQPException
|
||||||
|
* @expectedExceptionMessage Could not connect to the AMQP server. Please verify the provided DSN. ({"delay":{"routing_key_pattern":"delay_%delay%","exchange_name":"delay","queue_name_pattern":"delay_queue_%delay%"},"host":"localhost","port":5672,"vhost":"\/","login":"user","password":"********"})
|
||||||
|
*/
|
||||||
|
public function testObfuscatePasswordInDsn()
|
||||||
|
{
|
||||||
|
$factory = new TestAmqpFactory(
|
||||||
|
$amqpConnection = $this->createMock(\AMQPConnection::class),
|
||||||
|
$amqpChannel = $this->createMock(\AMQPChannel::class),
|
||||||
|
$amqpQueue = $this->createMock(\AMQPQueue::class),
|
||||||
|
$amqpExchange = $this->createMock(\AMQPExchange::class)
|
||||||
|
);
|
||||||
|
|
||||||
|
$amqpConnection->method('connect')->willThrowException(
|
||||||
|
new \AMQPConnectionException('Oups.')
|
||||||
|
);
|
||||||
|
|
||||||
|
$connection = Connection::fromDsn('amqp://user:secretpassword@localhost/%2f/messages', [], $factory);
|
||||||
|
$connection->channel();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
class TestAmqpFactory extends AmqpFactory
|
class TestAmqpFactory extends AmqpFactory
|
||||||
|
@ -317,7 +317,7 @@ class Connection
|
|||||||
try {
|
try {
|
||||||
$connection->{$connectMethod}();
|
$connection->{$connectMethod}();
|
||||||
} catch (\AMQPConnectionException $e) {
|
} catch (\AMQPConnectionException $e) {
|
||||||
$credentials = $this->connectionCredentials;
|
$credentials = $this->connectionConfiguration;
|
||||||
$credentials['password'] = '********';
|
$credentials['password'] = '********';
|
||||||
|
|
||||||
throw new \AMQPException(sprintf('Could not connect to the AMQP server. Please verify the provided DSN. (%s)', json_encode($credentials)), 0, $e);
|
throw new \AMQPException(sprintf('Could not connect to the AMQP server. Please verify the provided DSN. (%s)', json_encode($credentials)), 0, $e);
|
||||||
|
Reference in New Issue
Block a user