fix redis messenger options with dsn
This commit is contained in:
parent
d244e796b6
commit
a0e7bf4c0d
@ -85,6 +85,19 @@ class ConnectionTest extends TestCase
|
||||
);
|
||||
}
|
||||
|
||||
public function testFromDsnWithMixDsnQueryOptions()
|
||||
{
|
||||
$this->assertEquals(
|
||||
Connection::fromDsn('redis://localhost/queue/group1?serializer=2', ['consumer' => 'specific-consumer']),
|
||||
Connection::fromDsn('redis://localhost/queue/group1/specific-consumer?serializer=2')
|
||||
);
|
||||
|
||||
$this->assertEquals(
|
||||
Connection::fromDsn('redis://localhost/queue/group1/consumer1', ['consumer' => 'specific-consumer']),
|
||||
Connection::fromDsn('redis://localhost/queue/group1/consumer1')
|
||||
);
|
||||
}
|
||||
|
||||
public function testKeepGettingPendingMessages()
|
||||
{
|
||||
$redis = $this->getMockBuilder(\Redis::class)->disableOriginalConstructor()->getMock();
|
||||
|
@ -101,7 +101,8 @@ class Connection
|
||||
];
|
||||
|
||||
if (isset($parsedUrl['query'])) {
|
||||
parse_str($parsedUrl['query'], $redisOptions);
|
||||
parse_str($parsedUrl['query'], $dsnOptions);
|
||||
$redisOptions = array_merge($redisOptions, $dsnOptions);
|
||||
}
|
||||
|
||||
$autoSetup = null;
|
||||
|
Reference in New Issue
Block a user