@@ -39,7 +39,7 @@ class MultipleConsumerTest extends TestCase
3939 *
4040 * @return void
4141 */
42- public function setUp ()
42+ public function setUp (): void
4343 {
4444 $ this ->amqpConnection = $ this ->prepareAMQPConnection ();
4545 $ this ->amqpChannel = $ this ->prepareAMQPChannel ();
@@ -246,14 +246,14 @@ private function prepareAMQPChannelExpectations($expectedMethod, $expectedRequeu
246246 {
247247 $ this ->amqpChannel ->expects ($ this ->any ())
248248 ->method ('basic_reject ' )
249- ->will ($ this ->returnCallback (function ($ delivery_tag , $ requeue ) use ($ expectedMethod , $ expectedRequeue ) {
249+ ->will ($ this ->returnCallback (function ($ delivery_tag , $ requeue ) use ($ expectedMethod , $ expectedRequeue ) {
250250 Assert::assertSame ($ expectedMethod , 'basic_reject ' ); // Check if this function should be called.
251251 Assert::assertSame ($ requeue , $ expectedRequeue ); // Check if the message should be requeued.
252252 }));
253253
254254 $ this ->amqpChannel ->expects ($ this ->any ())
255255 ->method ('basic_ack ' )
256- ->will ($ this ->returnCallback (function ($ delivery_tag ) use ($ expectedMethod ) {
256+ ->will ($ this ->returnCallback (function ($ delivery_tag ) use ($ expectedMethod ) {
257257 Assert::assertSame ($ expectedMethod , 'basic_ack ' ); // Check if this function should be called.
258258 }));
259259 }
@@ -266,7 +266,7 @@ private function prepareAMQPChannelExpectations($expectedMethod, $expectedRequeu
266266 */
267267 private function prepareCallback ($ processFlag )
268268 {
269- return function ($ msg ) use (&$ lastQueue , $ processFlag ) {
269+ return function ($ msg ) use (&$ lastQueue , $ processFlag ) {
270270 return $ processFlag ;
271271 };
272272 }
0 commit comments