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()
|
public function testKeepGettingPendingMessages()
|
||||||
{
|
{
|
||||||
$redis = $this->getMockBuilder(\Redis::class)->disableOriginalConstructor()->getMock();
|
$redis = $this->getMockBuilder(\Redis::class)->disableOriginalConstructor()->getMock();
|
||||||
|
@ -101,7 +101,8 @@ class Connection
|
|||||||
];
|
];
|
||||||
|
|
||||||
if (isset($parsedUrl['query'])) {
|
if (isset($parsedUrl['query'])) {
|
||||||
parse_str($parsedUrl['query'], $redisOptions);
|
parse_str($parsedUrl['query'], $dsnOptions);
|
||||||
|
$redisOptions = array_merge($redisOptions, $dsnOptions);
|
||||||
}
|
}
|
||||||
|
|
||||||
$autoSetup = null;
|
$autoSetup = null;
|
||||||
|
Reference in New Issue
Block a user