@@ -281,12 +281,12 @@ public function testShouldBindCustomExecuteConsumptionAndUseCustomClientDestinat
281
281
->expects ($ driverInvoked )
282
282
->method ('createQueue ' )
283
283
->willReturnCallback (function (string $ queueName , bool $ prefix ) use ($ driverInvoked , $ defaultQueue , $ customQueue ) {
284
- match ($ driverInvoked ->getInvocationCount ()) {
284
+ match ($ driverInvoked ->getInvocationCount ()) {
285
285
1 => $ this ->assertSame (['default ' , true ], [$ queueName , $ prefix ]),
286
286
2 => $ this ->assertSame (['custom ' , true ], [$ queueName , $ prefix ]),
287
287
};
288
288
289
- return $ driverInvoked ->getInvocationCount () === 1 ? $ defaultQueue : $ customQueue ;
289
+ return 1 === $ driverInvoked ->getInvocationCount () ? $ defaultQueue : $ customQueue ;
290
290
})
291
291
;
292
292
$ consumerInvoked = $ this ->exactly (2 );
@@ -422,12 +422,12 @@ public function testShouldBindQueuesOnlyOnce()
422
422
->expects ($ invoked )
423
423
->method ('createQueue ' )
424
424
->willReturnCallback (function (string $ queueName , bool $ prefix ) use ($ defaultQueue , $ customQueue , $ invoked ) {
425
- match ($ invoked ->getInvocationCount ()) {
425
+ match ($ invoked ->getInvocationCount ()) {
426
426
1 => $ this ->assertSame (['default ' , true ], [$ queueName , $ prefix ]),
427
427
2 => $ this ->assertSame (['custom ' , true ], [$ queueName , $ prefix ]),
428
428
};
429
429
430
- return $ invoked ->getInvocationCount () === 1 ? $ defaultQueue : $ customQueue ;
430
+ return 1 === $ invoked ->getInvocationCount () ? $ defaultQueue : $ customQueue ;
431
431
})
432
432
;
433
433
@@ -437,7 +437,7 @@ public function testShouldBindQueuesOnlyOnce()
437
437
->expects ($ consumerInvoked )
438
438
->method ('bind ' )
439
439
->willReturnCallback (function ($ queueName , Processor $ argProcessor ) use ($ consumerInvoked , $ defaultQueue , $ processor , $ consumer , $ customQueue ) {
440
- match ($ consumerInvoked ->getInvocationCount ()) {
440
+ match ($ consumerInvoked ->getInvocationCount ()) {
441
441
1 => $ this ->assertSame ([$ defaultQueue , $ processor ], [$ queueName , $ argProcessor ]),
442
442
2 => $ this ->assertSame ([$ customQueue , $ processor ], [$ queueName , $ argProcessor ]),
443
443
};
0 commit comments