Skip to content

Commit 827fa10

Browse files
committed
[12.x] using redis cluster compatible queue name in test
1 parent 52afee5 commit 827fa10

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

tests/Integration/Queue/JobChainingTest.php

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -399,18 +399,18 @@ public function testBatchCanBeAddedToChain()
399399
public function testBatchInChainUsesCorrectQueue()
400400
{
401401
Bus::chain([
402-
(new JobChainingNamedTestJob('c1'))->onQueue('other'),
403-
(new JobChainingNamedTestJob('c2'))->onQueue('other'),
402+
(new JobChainingNamedTestJob('c1'))->onQueue('{other}'),
403+
(new JobChainingNamedTestJob('c2'))->onQueue('{other}'),
404404
Bus::batch([
405405
new JobChainingTestBatchedJob('b1'),
406406
new JobChainingTestBatchedJob('b2'),
407407
new JobChainingTestBatchedJob('b3'),
408408
new JobChainingTestBatchedJob('b4'),
409-
])->onQueue('other'),
410-
(new JobChainingNamedTestJob('c3'))->onQueue('other'),
409+
])->onQueue('{other}'),
410+
(new JobChainingNamedTestJob('c3'))->onQueue('{other}'),
411411
])->dispatch();
412412

413-
$this->runQueueWorkerCommand(['--queue' => 'other', '--stop-when-empty' => true]);
413+
$this->runQueueWorkerCommand(['--queue' => '{other}', '--stop-when-empty' => true]);
414414

415415
$this->assertEquals(['c1', 'c2', 'b1', 'b2', 'b3', 'b4', 'c3'], JobRunRecorder::$results);
416416
}

0 commit comments

Comments
 (0)